risingwave_stream::executor::test_utils::agg_executor

Function generate_agg_schema

source 
pub fn generate_agg_schema(
    input_ref: &Executor,
    agg_calls: &[AggCall],
    group_key_indices: Option<&[usize]>,
) -> Schema
Expand description

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