risingwave_stream::executor::aggregation

Trait Strategy

source 
pub trait Strategy {
    // Required method
    fn infer_change_type(
        ctx: &Context,
        prev_row: Option<&OwnedRow>,
        curr_row: &OwnedRow,
        row_count_col: usize,
    ) -> Option<RecordType>;
}

Required Methods§

source

fn infer_change_type( ctx: &Context, prev_row: Option<&OwnedRow>, curr_row: &OwnedRow, row_count_col: usize, ) -> Option<RecordType>

Infer the change type of the aggregation result. Don’t need to take the ownership of prev_row and curr_row.

Object Safety§

This trait is not object safe.

Implementors§