risingwave_frontend::optimizer::plan_node::logical_agg

Function new_stream_hash_agg

Source 
fn new_stream_hash_agg(
    core: Agg<StreamPlanRef>,
    vnode_col_idx: Option<usize>,
) -> Result<StreamHashAgg>