Crate mz_storage_operators

Shared Storage dataflow operators

Modules

metrics

Metrics for storage dataflow operators

oneshot_source

“Oneshot” sources are a one-time ingestion of data from an external system, unlike traditional sources, they do not run continuously. Oneshot sources are generally used for COPY FROM SQL statements.

persist_source

A source that reads from an a persist shard.

s3_oneshot_sink

Uploads a consolidated collection to S3

stats

Types and traits that connect up our mz-repr types with the stats that persist maintains.