Skip to main contentModule sink
Source - 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.
- materialized_view_v2 🔒
- Sync Timely operator implementation of the MV sink.
- refresh 🔒
- subscribe 🔒