compact_chunk_inline

risingwave_stream::common::compact_chunk

Function compact_chunk_inline 

Source 
pub fn compact_chunk_inline<const KIND: OutputKind>(
    stream_chunk: StreamChunk,
    key_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.