Module sinks

Source
Expand description

Logic related to the creation of dataflow sinks.

Traitsยง

SinkRender ๐Ÿ”’
A type that can be rendered as a dataflow sink.

Functionsยง

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.
zip_into_diff_pairs ๐Ÿ”’
Zip the input to a sink so that updates to the same key appear as DiffPairs.