Modulesยง
- compaction ๐
- prometheus ๐
Structsยง
- Iceberg
Commit ๐Result - Iceberg
Config - Iceberg
Sink - Iceberg
Sink Committer - Iceberg
Sink Writer - Iceberg
Writer Metrics
Enumsยง
Constantsยง
- DATA_
FILES ๐ - ICEBERG_
SINK - MAP_KEY ๐
- MAP_
VALUE ๐ - PARTITION_
SPEC_ ๐ID - SCHEMA_
ID ๐
Functionsยง
- check_
compatibility ๐ - default_
commit_ ๐retry_ num - deserialize_
metadata - get_
fields ๐ - serialize_
metadata - try_
matches_ arrow_ schema - Try to match our schema with iceberg schema.