risingwave_stream::common::table::state_table

Function fill_non_output_indices

Source 
fn fill_non_output_indices(
    i2o_mapping: &ColIndexMapping,
    data_types: &[DataType],
    chunk: StreamChunk,
) -> StreamChunk