fn retrieve_upper_from_snapshots(
snapshots: &mut [Arc<Snapshot>],
) -> Result<Option<(Antichain<Timestamp>, u64)>>Expand description
Find the most recent Materialize frontier from Iceberg snapshots. We store the frontier in snapshot metadata to track where we left off after restarts. Snapshots with operation=“replace” (compactions) don’t have our metadata and are skipped. The input slice will be sorted by sequence number in descending order.