compact_chunk_inline

risingwave_stream::common::compact_chunk

Function compact_chunk_inline 

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

Remove unnecessary changes in the given chunk, by modifying the visibility and ops in place. This is the same as StreamChunkCompactor::into_compacted_chunks_inline with only one chunk.