Structs§
Enums§
- Compaction
Type - Compaction type for Iceberg sink
- Iceberg
Write Mode
Constants§
- COMMIT_
CHECKPOINT_ SIZE_ THRESHOLD_ MB - COMPACTION_
DELETE_ FILES_ COUNT_ THRESHOLD - COMPACTION_
INTERVAL_ SEC - COMPACTION_
MAX_ SNAPSHOTS_ NUM - COMPACTION_
SMALL_ FILES_ THRESHOLD_ MB - COMPACTION_
TARGET_ FILE_ SIZE_ MB - COMPACTION_
TRIGGER_ SNAPSHOT_ COUNT - COMPACTION_
TYPE - COMPACTION_
WRITE_ PARQUET_ COMPRESSION - COMPACTION_
WRITE_ PARQUET_ MAX_ ROW_ GROUP_ ROWS - ENABLE_
COMPACTION - ENABLE_
SNAPSHOT_ EXPIRATION - FORMAT_
VERSION - ICEBERG_
COMPACTION_ TYPE_ FILES_ WITH_ DELETE - ICEBERG_
COMPACTION_ TYPE_ FULL - ICEBERG_
COMPACTION_ TYPE_ SMALL_ FILES - ICEBERG_
COW_ BRANCH - ICEBERG_
DEFAULT_ COMMIT_ CHECKPOINT_ SIZE_ THRESHOLD_ MB - ICEBERG_
WRITE_ MODE_ COPY_ ON_ WRITE - ICEBERG_
WRITE_ MODE_ MERGE_ ON_ READ - ORDER_
KEY - PARQUET_
CREATED_ 🔒BY - PARTITION_
DATA_ ID_ START - SNAPSHOT_
EXPIRATION_ CLEAR_ EXPIRED_ FILES - SNAPSHOT_
EXPIRATION_ CLEAR_ EXPIRED_ META_ DATA - SNAPSHOT_
EXPIRATION_ MAX_ AGE_ MILLIS - SNAPSHOT_
EXPIRATION_ RETAIN_ LAST - WRITE_
MODE
Functions§
- commit_
branch - default_
commit_ 🔒checkpoint_ size_ threshold_ mb - default_
commit_ 🔒retry_ num - default_
iceberg_ 🔒format_ version - default_
iceberg_ 🔒write_ mode - default_
some_ 🔒true - default_
true 🔒 - deserialize_
format_ 🔒version - parse_
format_ 🔒version_ str - parse_
parquet_ compression - Parse compression codec string to Parquet Compression enum
- should_
enable_ iceberg_ cow