Expand description
Types and traits related to reporting changing collections out of dataflow.
Modules§
Structs§
- Iceberg
Sink Connection - Kafka
Sink Connection - Kafka
Sink Format - S3Upload
Info - Info required to copy the data to s3.
- Storage
Sink Desc - A sink for updates to a relational collection.
Enums§
- Kafka
IdStyle - Kafka
Sink Compression Type - Kafka
Sink Format Type - S3Sink
Format - Sink
Envelope - Storage
Sink Connection
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.
- ICEBERG_
UINT64_ DECIMAL_ PRECISION - The precision needed to store all UInt64 values in a Decimal128. UInt64 max value is 18,446,744,073,709,551,615 which has 20 digits.
- MAX_
S3_ SINK_ FILE_ SIZE - MIN_
S3_ SINK_ FILE_ SIZE
Functions§
- iceberg_
type_ overrides - Type overrides for Iceberg-compatible Arrow schemas.