Skip to main content

Module iceberg_config

Module iceberg_config 

Source
Expand description

Apache Iceberg connector configuration.

IcebergSinkConfig and IcebergSourceConfig encapsulate settings for writing to and reading from Iceberg tables, parsed from SQL WITH (...) clauses via their respective from_config methods.

Structs§

IcebergCatalogConfig
Shared catalog connection settings for both source and sink.
IcebergSinkConfig
Configuration for the Iceberg sink connector.
IcebergSourceConfig
Configuration for the Iceberg source connector (lookup/reference table).

Enums§

IcebergCatalogType
Iceberg catalog type.

Functions§

validate_sink_schema
Validates that a pipeline’s output schema is compatible with an Iceberg table’s Arrow schema.