risingwave_stream::executor::nested_loop_temporal_join

Function phase1_handle_chunk

source 
fn phase1_handle_chunk<'_async0, S: StateStore, E: Phase1Evaluation>(
    chunk_size: usize,
    right_size: usize,
    full_schema: Vec<DataType>,
    epoch: HummockEpoch,
    right_table: &'_async0 mut TemporalSide<S>,
    chunk: StreamChunk,
) -> impl Stream<Item = Result<StreamChunk, StreamExecutorError>> + '_async0