risingwave_stream::executor::aggregation::agg_group

Function row_count_of

source 
fn row_count_of(
    ctx: &Context,
    row: Option<impl Row>,
    row_count_col: usize,
) -> usize