Trait tidb_query_common::execute_stats::ExecSummaryCollector

pub trait ExecSummaryCollector: Send {
    type DurationRecorder;
    fn new(output_index: usize) -> Self
    where
        Self: Sized;
    fn on_start_iterate(&mut self) -> Self::DurationRecorder;
    fn on_finish_iterate(&mut self, dr: Self::DurationRecorder, rows: usize);
    fn collect(&mut self, target: &mut [ExecSummary]);
}

A trait for all execution summary collectors.

Associated Types

type DurationRecorder

Loading content...

Required methods

fn new(output_index: usize) -> Self where
    Self: Sized, 

Creates a new instance with specified output slot index.

fn on_start_iterate(&mut self) -> Self::DurationRecorder

Returns an instance that will record elapsed duration and increase the iterations counter. The instance should be later passed back to on_finish_iterate when processing of next_batch is completed.

fn on_finish_iterate(&mut self, dr: Self::DurationRecorder, rows: usize)

fn collect(&mut self, target: &mut [ExecSummary])

Takes and appends current execution summary into target.

Loading content...

Implementors

impl ExecSummaryCollector for ExecSummaryCollectorDisabled

type DurationRecorder = ()

fn new(_output_index: usize) -> ExecSummaryCollectorDisabled

fn on_start_iterate(&mut self) -> Self::DurationRecorder

fn on_finish_iterate(&mut self, _dr: Self::DurationRecorder, _rows: usize)

fn collect(&mut self, _target: &mut [ExecSummary])

impl ExecSummaryCollector for ExecSummaryCollectorEnabled

type DurationRecorder = Instant

fn new(output_index: usize) -> ExecSummaryCollectorEnabled

fn on_start_iterate(&mut self) -> Self::DurationRecorder

fn on_finish_iterate(&mut self, dr: Self::DurationRecorder, rows: usize)

fn collect(&mut self, target: &mut [ExecSummary])

Loading content...