Struct tidb_query_executors::BatchFastHashAggregationExecutor

pub struct BatchFastHashAggregationExecutor<Src: BatchExecutor>(AggregationExecutor<Src, FastHashAggregationImpl>);

Fast Hash Aggregation Executor uses hash when comparing group key. It only supports one group by column.

Implementations

impl BatchFastHashAggregationExecutor<Box<dyn BatchExecutor<StorageStats = ()>>>

pub fn check_supported(descriptor: &Aggregation) -> Result<()>

Checks whether this executor can be used.

impl<Src: BatchExecutor> BatchFastHashAggregationExecutor<Src>

pub fn new(
    config: Arc<EvalConfig>,
    src: Src,
    group_by_exp_defs: Vec<Expr>,
    aggr_defs: Vec<Expr>
) -> Result<Self>

fn new_impl(
    config: Arc<EvalConfig>,
    src: Src,
    group_by_exp: RpnExpression,
    aggr_defs: Vec<Expr>,
    aggr_def_parser: impl AggrDefinitionParser
) -> Result<Self>

Trait Implementations

impl<Src: BatchExecutor> BatchExecutor for BatchFastHashAggregationExecutor<Src>

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,