risingwave_stream::common::compact_chunk

Function merge_chunk_row

source 
pub fn merge_chunk_row(
    stream_chunk: StreamChunk,
    pk_indices: &[usize],
) -> StreamChunk