Skip to main content

Module iceberg_reference

Module iceberg_reference 

Source
Expand description

Iceberg reference table source for lookup/enrichment joins.

Implements ReferenceTableSource to populate a dimension table from an Iceberg table. Delivers snapshot data as batches, then polls for new snapshots to deliver incremental changes via manifest diff.

Structsยง

IcebergReferenceTableSource
Iceberg reference table source for lookup/enrichment joins.