risingwave_stream::executor::temporal_join

Function apply_indices_map

Source 
pub(super) fn apply_indices_map(
    chunk: StreamChunk,
    indices: &[usize],
) -> StreamChunk