risingwave_stream::executor::aggregate::agg_group

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.

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors§