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

DATA_FILES 🔒

DEFAULT_ICEBERG_COMPACTION_INTERVAL

ICEBERG_SINK

MAP_KEY 🔒

MAP_VALUE 🔒

PARTITION_SPEC_ID 🔒

SCHEMA_ID 🔒

Functions

check_compatibility 🔒

default_commit_retry_num 🔒

deserialize_metadata

get_fields 🔒

parse_partition_by_exprs

serialize_metadata

try_matches_arrow_schema

Try to match our schema with iceberg schema.