Module iceberg_io 

Feature-gated I/O operations for Apache Iceberg.

Contains catalog construction, table loading, scanning, and writing functions. All code requires the iceberg feature.

Functions

build_catalog

Builds a REST catalog from configuration.

commit_data_files

Commits data files to an Iceberg table via a fast-append transaction.

current_snapshot_id

Returns the current snapshot ID of a table, if any.

ensure_table_exists

Creates an Iceberg table (and namespace) if it does not already exist.

get_last_committed_epoch

Reads the last committed epoch for a writer from Iceberg table properties.

load_table

Loads an Iceberg table from the catalog.

scan_table

Scans a table and returns all record batches for the current snapshot.