prune_additional_cols

risingwave_stream::executor::source

Function prune_additional_cols 

Source 
pub fn prune_additional_cols(
    chunk: &StreamChunk,
    split_idx: usize,
    offset_idx: usize,
    column_descs: &[SourceColumnDesc],
) -> StreamChunk