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.

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.