Struct tidb_query_executors::fast_hash_aggr_executor::FastHashAggregationImpl

pub struct FastHashAggregationImpl {
    states: Vec<Box<dyn AggrFunctionState>>,
    groups: Groups,
    group_by_exp: RpnExpression,
    group_by_field_type: FieldType,
    states_offset_each_logical_row: Vec<usize>,
}

Fields

states: Vec<Box<dyn AggrFunctionState>>

groups: Groups

group_by_exp: RpnExpression

group_by_field_type: FieldType

states_offset_each_logical_row: Vec<usize>

Trait Implementations

impl<Src: BatchExecutor> AggregationExecutorImpl<Src> for FastHashAggregationImpl

fn prepare_entities(&mut self, entities: &mut Entities<Src>)

Accepts entities without any group by columns and modifies them optionally.

fn process_batch_input(
    &mut self,
    entities: &mut Entities<Src>,
    input_physical_columns: LazyBatchColumnVec,
    input_logical_rows: &[usize]
) -> Result<()>

Processes a set of columns which are emitted from the underlying executor.

fn groups_len(&self) -> usize

Returns the current number of groups.

fn iterate_available_groups(
    &mut self,
    entities: &mut Entities<Src>,
    src_is_drained: bool,
    iteratee: impl FnMut(&mut Entities<Src>, &[Box<dyn AggrFunctionState>]) -> Result<()>
) -> Result<Vec<LazyBatchColumn>>

Iterates aggregate function states for each available group.

fn is_partial_results_ready(&self) -> bool

Fast hash aggregation can output aggregate results only if the source is drained.