risingwave_frontend::optimizer::plan_node::logical_agg

Function new_stream_simple_agg

Source 
fn new_stream_simple_agg(
    core: Agg<PlanRef>,
    must_output_per_barrier: bool,
) -> StreamSimpleAgg