Module sinks

Source
Expand description

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

Modules§

s3_oneshot_sink

Structs§

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§

MAX_S3_SINK_FILE_SIZE
MIN_S3_SINK_FILE_SIZE