risingwave_stream::executor::temporal_join::phase1

Trait Phase1Evaluation

Source 
pub trait Phase1Evaluation {
    // Required methods
    fn append_matched_row(
        op: Op,
        builder: &mut StreamChunkBuilder,
        left_row: impl Row,
        right_row: impl Row,
    ) -> Option<StreamChunk>;
    fn match_end(
        builder: &mut StreamChunkBuilder,
        op: Op,
        left_row: impl Row,
        right_size: usize,
        matched: bool,
    ) -> Option<StreamChunk>;
}

Required Methods§

Source

fn append_matched_row( op: Op, builder: &mut StreamChunkBuilder, left_row: impl Row, right_row: impl Row, ) -> Option<StreamChunk>

Called when a matched row is found.

Source

fn match_end( builder: &mut StreamChunkBuilder, op: Op, left_row: impl Row, right_size: usize, matched: bool, ) -> Option<StreamChunk>

Called when all matched rows of a join key are appended.

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§