risingwave_frontend::optimizer::plan_node::logical_agg

Function new_stream_simple_agg

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