risingwave_stream::common::compact_chunk

Function merge_chunk_row

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