Skip to main content

Module change_buffer

risingwave_stream::common

Module change_buffer 

Source

Modules§

output_kind
private 🔒

Structs§

ChangeBuffer
A buffer that accumulates changes and produce compacted changes.
Slot 🔒
The accumulated change of a key, with each side in an Option so that state transitions can take one side out in place. (None, None) entries are removed eagerly.

Enums§

InconsistencyBehavior
Behavior when inconsistency is detected when aggregating changes to ChangeBuffer.

Type Aliases§

OutputKind
The kind of output for ChangeBuffer::into_chunk and ChangeBuffer::into_chunks. Can be UPSERT or RETRACT.