risingwave_stream::executor::aggregate::agg_group

Function row_count_of

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