Module compact_chunk

risingwave_stream::common

Module compact_chunk 

Source

Re-exports§

pub use super::change_buffer::InconsistencyBehavior;

Structs§

StreamChunkCompactor
A helper to remove unnecessary changes in the stream chunks based on the key.

Functions§

compact_chunk_inline
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.