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);
}
/**