Struct tidb_query_executors::util::aggr_executor::AggregationExecutor

pub struct AggregationExecutor<Src: BatchExecutor, I: AggregationExecutorImpl<Src>> {
    imp: I,
    is_ended: bool,
    entities: Entities<Src>,
}

A shared executor implementation for simple aggregation, hash aggregation and stream aggregation. Implementation differences are further given via AggregationExecutorImpl.

Fields

imp: I

is_ended: bool

entities: Entities<Src>

Implementations

impl<Src: BatchExecutor, I: AggregationExecutorImpl<Src>> AggregationExecutor<Src, I>

pub fn new(
    imp: I,
    src: Src,
    config: Arc<EvalConfig>,
    aggr_defs: Vec<Expr>,
    aggr_def_parser: impl AggrDefinitionParser
) -> Result<Self>

fn handle_next_batch(&mut self) -> Result<(Option<LazyBatchColumnVec>, bool)>

Returns partial results of aggregation if available and whether the source is drained

fn aggregate_partial_results(
    &mut self,
    src_is_drained: bool
) -> Result<LazyBatchColumnVec>

Generates aggregation results of available groups.

Trait Implementations

impl<Src: BatchExecutor, I: AggregationExecutorImpl<Src>> BatchExecutor for AggregationExecutor<Src, I>

type StorageStats = Src::StorageStats

fn schema(&self) -> &[FieldType]

Gets the schema of the output.

fn next_batch(&mut self, _scan_rows: usize) -> BatchExecuteResult

Pulls next several rows of data (stored by column).

fn collect_exec_stats(&mut self, dest: &mut ExecuteStats)

Collects execution statistics (including but not limited to metrics and execution summaries) accumulated during execution and prepares for next collection.

fn collect_storage_stats(&mut self, dest: &mut Self::StorageStats)

Collects underlying storage statistics accumulated during execution and prepares for next collection.

fn take_scanned_range(&mut self) -> IntervalRange

fn can_be_cached(&self) -> bool

fn collect_summary(
    self,
    output_index: usize
) -> WithSummaryCollector<ExecSummaryCollectorEnabled, Self> where
    Self: Sized,