This is an automated email from the ASF dual-hosted git repository.

russellspitzer pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg.git


The following commit(s) were added to refs/heads/main by this push:
     new 469c5560b2 Core: use ManifestFiles.open when possible (#11414)
469c5560b2 is described below

commit 469c5560b26f8c0eb18bd04be8f4d8fb1fd87c20
Author: Hongyue/Steve Zhang <[email protected]>
AuthorDate: Tue Oct 29 13:03:38 2024 -0700

    Core: use ManifestFiles.open when possible (#11414)
---
 core/src/main/java/org/apache/iceberg/BaseFilesTable.java | 10 +---------
 1 file changed, 1 insertion(+), 9 deletions(-)

diff --git a/core/src/main/java/org/apache/iceberg/BaseFilesTable.java 
b/core/src/main/java/org/apache/iceberg/BaseFilesTable.java
index b71744f739..4dff19b879 100644
--- a/core/src/main/java/org/apache/iceberg/BaseFilesTable.java
+++ b/core/src/main/java/org/apache/iceberg/BaseFilesTable.java
@@ -181,15 +181,7 @@ abstract class BaseFilesTable extends BaseMetadataTable {
     }
 
     private CloseableIterable<? extends ContentFile<?>> files(Schema 
fileProjection) {
-      switch (manifest.content()) {
-        case DATA:
-          return ManifestFiles.read(manifest, io, 
specsById).project(fileProjection);
-        case DELETES:
-          return ManifestFiles.readDeleteManifest(manifest, io, 
specsById).project(fileProjection);
-        default:
-          throw new IllegalArgumentException(
-              "Unsupported manifest content type:" + manifest.content());
-      }
+      return ManifestFiles.open(manifest, io, 
specsById).project(fileProjection);
     }
 
     /**

Reply via email to