Module sink

risingwave_stream::executor

Module sink 

Source

Macros§

dispatch_output_kind 🔒
Dispatch the code block to different output kinds for chunk compaction based on sink type.

Structs§

NonAppendOnlyBehavior 🔒
When the sink is non-append-only, i.e. upsert or retract, we need to do some extra work for correctness and performance.
SinkExecutor

Enums§

RebuildSinkMessage 🔒

Functions§

compact_output_kind 🔒
Get the output kind for chunk compaction based on the given sink type.
force_append_only 🔒
force_delete_only 🔒