Module sinks

Source
Expand description

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

Modules§

proto_kafka_id_style
Nested message and enum types in ProtoKafkaIdStyle.
proto_kafka_sink_connection_v2
Nested message and enum types in ProtoKafkaSinkConnectionV2.
proto_kafka_sink_format_type
Nested message and enum types in ProtoKafkaSinkFormatType.
proto_s3_sink_format
Nested message and enum types in ProtoS3SinkFormat.
proto_sink_envelope
Nested message and enum types in ProtoSinkEnvelope.
proto_storage_sink_connection
Nested message and enum types in ProtoStorageSinkConnection.
s3_oneshot_sink

Structs§

KafkaSinkConnection
KafkaSinkFormat
ProtoKafkaIdStyle
ProtoKafkaSinkConnectionV2
ProtoKafkaSinkFormat
ProtoKafkaSinkFormatType
ProtoPersistSinkConnection
ProtoS3SinkFormat
ProtoS3UploadInfo
ProtoSinkEnvelope
ProtoStorageSinkConnection
ProtoStorageSinkDesc
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

Functions§

csr_compat_level_from_proto 🔒
csr_compat_level_to_proto 🔒