risingwave_stream::executor::temporal_join::phase1

Function handle_chunk

source 
pub(super) fn handle_chunk<'a, K: HashKey, S: StateStore, E: Phase1Evaluation, const APPEND_ONLY: bool>(
    chunk_size: usize,
    right_size: usize,
    full_schema: Vec<DataType>,
    epoch: HummockEpoch,
    left_join_keys: &'a [usize],
    right_table: &'a mut TemporalSide<K, S>,
    memo_table_lookup_prefix: &'a [usize],
    memo_table: &'a mut Option<StateTable<S>>,
    null_matched: &'a K::Bitmap,
    chunk: StreamChunk,
    metrics: &'a TemporalJoinMetrics,
) -> impl Stream<Item = Result<StreamChunk, StreamExecutorError>> + 'a