Module writer

risingwave_connector::sink::iceberg

Module writer 

Source

Structs§

IcebergSinkWriterArgs
IcebergSinkWriterInner
IcebergWriterMetrics
SharedIcebergWriterBuilder 🔒
TaskWriterBuilderWrapper 🔒

Enums§

IcebergSinkWriter
IcebergWriterDispatch 🔒
PositionDeleteWriterBuilderType 🔒
PositionDeleteWriterType 🔒
ProjectIdxVec 🔒
None means no project. Prepare represent the extra partition column idx. Done represents the project idx vec.

Constants§

MAX_COLUMN_STAT_SIZE 🔒
Maximum size for column statistics (min/max values) in bytes. Column statistics larger than this will be truncated to avoid metadata bloat. This is especially important for large fields like JSONB, TEXT, BINARY, etc.

Functions§

truncate_datafile 🔒
Truncate large column statistics from DataFile BEFORE serialization.

Type Aliases§

DataFileWriterBuilderType 🔒
DeletionVectorWriterBuilderType 🔒
DeletionVectorWriterType 🔒
EqualityDeleteFileWriterBuilderType 🔒
PositionDeleteFileWriterBuilderType 🔒
PositionDeleteFileWriterType 🔒