Module iceberg

Modules

exactly_once_util

prometheus 🔒

Structs

IcebergCommitResult 🔒

IcebergConfig

IcebergSink

IcebergSinkCommitter

IcebergSinkWriter

IcebergWriterMetrics

Enums

IcebergWriterDispatch 🔒

ProjectIdxVec 🔒

None means no project. Prepare represent the extra partition column idx. Done represents the project idx vec.

Constants

COMPACTION_INTERVAL_SEC

DATA_FILES 🔒

ENABLE_COMPACTION

ENABLE_SNAPSHOT_EXPIRATION

ICEBERG_COW_BRANCH

ICEBERG_SINK

ICEBERG_WRITE_MODE_COPY_ON_WRITE

ICEBERG_WRITE_MODE_MERGE_ON_READ

MAP_KEY 🔒

MAP_VALUE 🔒

PARTITION_SPEC_ID 🔒

SCHEMA_ID 🔒

WRITE_MODE

Functions

check_compatibility 🔒

commit_branch

default_commit_retry_num 🔒

default_iceberg_write_mode 🔒

deserialize_metadata

get_fields 🔒

parse_partition_by_exprs

serialize_metadata

should_enable_iceberg_cow

try_matches_arrow_schema

Try to match our schema with iceberg schema.