Module iceberg

Modules§

commit 🔒
commit_retry: Shared iceberg commit-with-retry primitive used by both the V1/V2 sink committer and the V3 sink coordinator worker. Wraps the standard pattern of “reload the table, build an action against the freshly-loaded snapshot, commit, retry on transient errors only”.
config 🔒
create_table 🔒
prometheus 🔒
writer 🔒

commit_branch
create_and_validate_table_impl
parse_order_key_exprs
parse_parquet_compression: Parse compression codec string to Parquet Compression enum
parse_partition_by_exprs
resolve_partition_spec: Resolves a partition spec by id from the table metadata, with a consolidated error message. Shared spec-lookup mechanic for the pk-index merger, commit coordinator, and sink commit paths.
resolve_partition_type: Resolves the partition [StructType] for the given spec_id against schema.
serialize_data_files_default_spec: Serializes files against the table’s current default partition spec, after truncating oversized column statistics. Shared by the iceberg sink writer’s commit-metadata generation and the pk-index merger’s delete-file serialization.
should_enable_iceberg_cow
truncate_datafile: Truncate large column statistics from DataFile BEFORE serialization.
try_matches_arrow_schema: Try to match our schema with iceberg schema.
validate_order_key_columns

PositionDeleteFileWriterBuilderType: The concrete V2 position-delete Parquet writer builder type, shared by the iceberg sink writer and the pk-index position-delete merger.