Module sinks 

Types and traits related to reporting changing collections out of dataflow.

Modules

s3_oneshot_sink

Structs

IcebergSinkConnection

KafkaSinkConnection

KafkaSinkFormat

S3UploadInfo

Info required to copy the data to s3.

StorageSinkDesc

A sink for updates to a relational collection.

Enums

KafkaIdStyle

KafkaSinkCompressionType

KafkaSinkFormatType

S3SinkFormat

SinkEnvelope

StorageSinkConnection

Constants

ICEBERG_APPEND_DIFF_COLUMN

Column name appended by MODE APPEND Iceberg sinks to record the diff (+1/−1).

ICEBERG_APPEND_TIMESTAMP_COLUMN

Column name appended by MODE APPEND Iceberg sinks to record the logical timestamp.

MAX_S3_SINK_FILE_SIZE

MIN_S3_SINK_FILE_SIZE