Skip to main content

risingwave_iceberg_commit_epoch

Function risingwave_iceberg_commit_epoch 

Source
fn risingwave_iceberg_commit_epoch(
    metadata: &TableMetadata,
    snapshot_id: i64,
) -> Option<u64>
Expand description

Find the latest known RisingWave commit boundary. Iceberg compaction produces replace snapshots without changing table contents, so the marker is inherited across a chain of those snapshots. We deliberately stop at any other unmarked operation: an external or legacy append cannot be assigned a safe log-store boundary.