fix

apache · Sep 18, 2024 · 31ea0f3 · 31ea0f3
1 parent 30e0292
commit 31ea0f3
Show file tree

Hide file tree

Showing 5 changed files with 5 additions and 13 deletions.
diff --git a/paimon-core/src/main/java/org/apache/paimon/AbstractFileStore.java b/paimon-core/src/main/java/org/apache/paimon/AbstractFileStore.java
@@ -177,8 +177,7 @@ public StatsFileHandler newStatsFileHandler() {
                 new StatsFile(fileIO, pathFactory().statsFileFactory()));
     }
 
-    @Override
-    public ManifestsReader newManifestPlanner(boolean forWrite) {
+    protected ManifestsReader newManifestsReader(boolean forWrite) {
         return new ManifestsReader(partitionType, snapshotManager(), manifestListFactory(forWrite));
     }
 

diff --git a/paimon-core/src/main/java/org/apache/paimon/AppendOnlyFileStore.java b/paimon-core/src/main/java/org/apache/paimon/AppendOnlyFileStore.java
@@ -136,7 +136,7 @@ public void pushdown(Predicate predicate) {
                 };
 
         return new AppendOnlyFileStoreScan(
-                newManifestPlanner(forWrite),
+                newManifestsReader(forWrite),
                 partitionType,
                 bucketFilter,
                 snapshotManager(),

diff --git a/paimon-core/src/main/java/org/apache/paimon/FileStore.java b/paimon-core/src/main/java/org/apache/paimon/FileStore.java
@@ -28,7 +28,6 @@
 import org.apache.paimon.operation.FileStoreCommit;
 import org.apache.paimon.operation.FileStoreScan;
 import org.apache.paimon.operation.FileStoreWrite;
-import org.apache.paimon.operation.ManifestsReader;
 import org.apache.paimon.operation.PartitionExpire;
 import org.apache.paimon.operation.SnapshotDeletion;
 import org.apache.paimon.operation.SplitRead;
@@ -66,12 +65,6 @@ public interface FileStore<T> {
 
     BucketMode bucketMode();
 
-    default ManifestsReader newManifestPlanner() {
-        return newManifestPlanner(false);
-    }
-
-    ManifestsReader newManifestPlanner(boolean forWrite);
-
     FileStoreScan newScan();
 
     ManifestList.Factory manifestListFactory();

diff --git a/paimon-core/src/main/java/org/apache/paimon/KeyValueFileStore.java b/paimon-core/src/main/java/org/apache/paimon/KeyValueFileStore.java
@@ -229,7 +229,7 @@ public void pushdown(Predicate keyFilter) {
                     }
                 };
         return new KeyValueFileStoreScan(
-                newManifestPlanner(forWrite),
+                newManifestsReader(forWrite),
                 partitionType,
                 bucketFilter,
                 snapshotManager(),

diff --git a/paimon-core/src/main/java/org/apache/paimon/privilege/PrivilegedFileStore.java b/paimon-core/src/main/java/org/apache/paimon/privilege/PrivilegedFileStore.java
@@ -93,8 +93,8 @@ public BucketMode bucketMode() {
     }
 
     @Override
-    public ManifestsReader newManifestPlanner(boolean forWrite) {
-        return wrapped.newManifestPlanner(forWrite);
+    public ManifestsReader newManifestsReader(boolean forWrite) {
+        return wrapped.newManifestsReader(forWrite);
     }
 
     @Override