Module sink

Modules

copy_to_s3_oneshot 🔒

correction 🔒

The Correction data structure used by persist_sink::write_batches to stash updates before they are written into batches.

correction_v2 🔒

An implementation of the Correction data structure used by the MV sink’s write_batches operator to stash updates before they are written.

materialized_view 🔒

A dataflow sink that writes input records to a persist shard.

refresh 🔒

subscribe 🔒