Module agg_executor

Functions

create_agg_state_storage

Create state storage for the given agg call. Should infer the schema in the same way as LogicalAgg::infer_stream_agg_state.

create_intermediate_state_table

Create intermediate state table for agg executor.

generate_agg_schema

Generate aggExecuter’s schema from input, agg_calls and group_key_indices. For crate::executor::aggregate::HashAggExecutor, the group key indices should be provided.

new_boxed_hash_agg_executor

NOTE(kwannoel): This should only be used by test or bench.

new_boxed_simple_agg_executor