Skip to main content

commit_data_files

Function commit_data_files 

Source
pub async fn commit_data_files(
    table: &Table,
    catalog: &dyn Catalog,
    data_files: Vec<DataFile>,
    epoch_metadata: Option<(&str, u64)>,
) -> Result<Table, ConnectorError>
Expand description

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

When epoch_metadata is provided, also stores writer_id and epoch in table properties for exactly-once recovery. Both the data append and property update are committed atomically in a single transaction.

Returns the updated table with the new snapshot.

ยงErrors

Returns ConnectorError::TransactionError on commit failure.