Functions§
- 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 for agg executor.
- Generate aggExecuter’s schema from
input
,agg_calls
andgroup_key_indices
. Forcrate::executor::HashAggExecutor
, the group key indices should be provided. - NOTE(kwannoel): This should only be used by
test
orbench
.