Implementation

revolut-engineering · Feb 8, 2024 · 46de11c · 46de11c
1 parent 6215ff6
commit 46de11c
Show file tree

Hide file tree

Showing 3 changed files with 239 additions and 64 deletions.
diff --git a/core/src/main/java/org/apache/iceberg/ManifestFiles.java b/core/src/main/java/org/apache/iceberg/ManifestFiles.java
@@ -101,7 +101,7 @@ public static CloseableIterable<String> readPaths(ManifestFile manifest, FileIO
   public static CloseableIterable<Pair<String, Long>> readPathsWithSnapshotId(
       ManifestFile manifest, FileIO io) {
     return CloseableIterable.transform(
-        read(manifest, io, null).select(ImmutableList.of("file_path", "snapshot_id")).liveEntries(),
+        open(manifest, io, null).select(ImmutableList.of("file_path", "snapshot_id")).liveEntries(),
         entry -> Pair.of(entry.file().path().toString(), entry.snapshotId()));
   }