risingwave_stream::executor::aggregation::agg_group

Trait Strategy

source 
pub trait Strategy {
    // Required method
    fn infer_change_type(
        prev_row_count: usize,
        curr_row_count: usize,
        prev_outputs: Option<&OwnedRow>,
        curr_outputs: &OwnedRow,
    ) -> Option<RecordType>;
}

Required Methods§

source

fn infer_change_type( prev_row_count: usize, curr_row_count: usize, prev_outputs: Option<&OwnedRow>, curr_outputs: &OwnedRow, ) -> Option<RecordType>

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

Object Safety§

This trait is not object safe.

Implementors§