Skip to main content

get_last_committed_epoch

laminar_connectors::lakehouse::delta_io

Function get_last_committed_epoch 

Source 
pub async fn get_last_committed_epoch(
    table: &DeltaTable,
    writer_id: &str,
) -> u64
Expand description

Retrieves the last committed epoch for a writer from Delta Lake’s txn metadata.

This is used for exactly-once recovery: on startup, we check what epoch was last committed and skip any epochs <= that value.

§Arguments

  • table - The Delta Lake table handle
  • writer_id - The writer identifier to look up

§Returns

The last committed epoch for this writer, or 0 if no commits found.