Module sinks 

Logic related to the creation of dataflow sinks.

Structs

PkViolationWarner 🔒

Rate-limited detector for primary-key uniqueness violations as a sink’s cursor walk observes (key, timestamp) groups.

Traits

SinkRender 🔒

A type that can be rendered as a dataflow sink.

Functions

arrange_sink_input 🔒

Extract the sink’s key column(s) from each row, arrange the resulting (Option<Row>, Row) collection by key, and return just the stream of batches — dropping the trace reader.

get_sink_render_for 🔒

render_sink 🔒

Renders complete differential collections that represent the sink and its errors as requested by the original CREATE SINK statement.

Type Aliases

SinkBatchStream 🔒

Stream of arrangement batches handed to SinkRender::render_sink.

SinkTrace 🔒

The concrete trace type produced internally when arranging a sink’s input. The sink never sees this directly — only the batches flowing through it — but it’s the anchor for the batch type in SinkBatchStream.