risingwave_stream::executor::backfill::utils

Function mapping_chunk

Source 
pub(crate) fn mapping_chunk(
    chunk: StreamChunk,
    output_indices: &[usize],
) -> StreamChunk
Expand description

Builds a new stream chunk with output_indices.