This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
The following commit(s) were added to refs/heads/master by this push:
new 8193b8671 [core] Implement some methods in DelegatedFileStoreTable
8193b8671 is described below
commit 8193b8671336226a6e08e087dd011dc426ebab75
Author: Jingsong <[email protected]>
AuthorDate: Thu Sep 5 18:10:29 2024 +0800
[core] Implement some methods in DelegatedFileStoreTable
---
.../paimon/privilege/PrivilegedFileStoreTable.java | 19 -------------------
.../apache/paimon/table/DelegatedFileStoreTable.java | 19 +++++++++++++++++++
.../paimon/table/FallbackReadFileStoreTable.java | 19 -------------------
3 files changed, 19 insertions(+), 38 deletions(-)
diff --git
a/paimon-core/src/main/java/org/apache/paimon/privilege/PrivilegedFileStoreTable.java
b/paimon-core/src/main/java/org/apache/paimon/privilege/PrivilegedFileStoreTable.java
index 5809efef5..6842f0142 100644
---
a/paimon-core/src/main/java/org/apache/paimon/privilege/PrivilegedFileStoreTable.java
+++
b/paimon-core/src/main/java/org/apache/paimon/privilege/PrivilegedFileStoreTable.java
@@ -20,10 +20,7 @@ package org.apache.paimon.privilege;
import org.apache.paimon.FileStore;
import org.apache.paimon.catalog.Identifier;
-import org.apache.paimon.manifest.IndexManifestEntry;
import org.apache.paimon.manifest.ManifestCacheFilter;
-import org.apache.paimon.manifest.ManifestEntry;
-import org.apache.paimon.manifest.ManifestFileMeta;
import org.apache.paimon.schema.TableSchema;
import org.apache.paimon.stats.Statistics;
import org.apache.paimon.table.DelegatedFileStoreTable;
@@ -38,7 +35,6 @@ import org.apache.paimon.table.source.InnerTableRead;
import org.apache.paimon.table.source.StreamDataTableScan;
import org.apache.paimon.table.source.snapshot.SnapshotReader;
import org.apache.paimon.utils.BranchManager;
-import org.apache.paimon.utils.SimpleFileReader;
import org.apache.paimon.utils.TagManager;
import java.time.Duration;
@@ -95,21 +91,6 @@ public class PrivilegedFileStoreTable extends
DelegatedFileStoreTable {
wrapped.copy(dynamicOptions), privilegeChecker, identifier);
}
- @Override
- public SimpleFileReader<ManifestFileMeta> manifestListReader() {
- return wrapped.manifestListReader();
- }
-
- @Override
- public SimpleFileReader<ManifestEntry> manifestFileReader() {
- return wrapped.manifestFileReader();
- }
-
- @Override
- public SimpleFileReader<IndexManifestEntry> indexManifestFileReader() {
- return wrapped.indexManifestFileReader();
- }
-
@Override
public FileStoreTable copy(TableSchema newTableSchema) {
return new PrivilegedFileStoreTable(
diff --git
a/paimon-core/src/main/java/org/apache/paimon/table/DelegatedFileStoreTable.java
b/paimon-core/src/main/java/org/apache/paimon/table/DelegatedFileStoreTable.java
index a82d18247..a60e17496 100644
---
a/paimon-core/src/main/java/org/apache/paimon/table/DelegatedFileStoreTable.java
+++
b/paimon-core/src/main/java/org/apache/paimon/table/DelegatedFileStoreTable.java
@@ -23,7 +23,10 @@ import org.apache.paimon.FileStore;
import org.apache.paimon.Snapshot;
import org.apache.paimon.fs.FileIO;
import org.apache.paimon.fs.Path;
+import org.apache.paimon.manifest.IndexManifestEntry;
import org.apache.paimon.manifest.ManifestCacheFilter;
+import org.apache.paimon.manifest.ManifestEntry;
+import org.apache.paimon.manifest.ManifestFileMeta;
import org.apache.paimon.schema.TableSchema;
import org.apache.paimon.stats.Statistics;
import org.apache.paimon.table.query.LocalTableQuery;
@@ -37,6 +40,7 @@ import org.apache.paimon.table.source.StreamDataTableScan;
import org.apache.paimon.table.source.snapshot.SnapshotReader;
import org.apache.paimon.utils.BranchManager;
import org.apache.paimon.utils.SegmentsCache;
+import org.apache.paimon.utils.SimpleFileReader;
import org.apache.paimon.utils.SnapshotManager;
import org.apache.paimon.utils.TagManager;
@@ -134,6 +138,21 @@ public abstract class DelegatedFileStoreTable implements
FileStoreTable {
return wrapped.snapshot(snapshotId);
}
+ @Override
+ public SimpleFileReader<ManifestFileMeta> manifestListReader() {
+ return wrapped.manifestListReader();
+ }
+
+ @Override
+ public SimpleFileReader<ManifestEntry> manifestFileReader() {
+ return wrapped.manifestFileReader();
+ }
+
+ @Override
+ public SimpleFileReader<IndexManifestEntry> indexManifestFileReader() {
+ return wrapped.indexManifestFileReader();
+ }
+
@Override
public void rollbackTo(long snapshotId) {
wrapped.rollbackTo(snapshotId);
diff --git
a/paimon-core/src/main/java/org/apache/paimon/table/FallbackReadFileStoreTable.java
b/paimon-core/src/main/java/org/apache/paimon/table/FallbackReadFileStoreTable.java
index 6a06e4d5d..60d0db791 100644
---
a/paimon-core/src/main/java/org/apache/paimon/table/FallbackReadFileStoreTable.java
+++
b/paimon-core/src/main/java/org/apache/paimon/table/FallbackReadFileStoreTable.java
@@ -23,9 +23,6 @@ import org.apache.paimon.Snapshot;
import org.apache.paimon.data.BinaryRow;
import org.apache.paimon.data.InternalRow;
import org.apache.paimon.disk.IOManager;
-import org.apache.paimon.manifest.IndexManifestEntry;
-import org.apache.paimon.manifest.ManifestEntry;
-import org.apache.paimon.manifest.ManifestFileMeta;
import org.apache.paimon.manifest.PartitionEntry;
import org.apache.paimon.metrics.MetricRegistry;
import org.apache.paimon.predicate.Predicate;
@@ -42,7 +39,6 @@ import org.apache.paimon.types.DataType;
import org.apache.paimon.types.RowType;
import org.apache.paimon.utils.Filter;
import org.apache.paimon.utils.Preconditions;
-import org.apache.paimon.utils.SimpleFileReader;
import java.io.IOException;
import java.util.ArrayList;
@@ -77,21 +73,6 @@ public class FallbackReadFileStoreTable extends
DelegatedFileStoreTable {
fallback.copy(rewriteFallbackOptions(dynamicOptions)));
}
- @Override
- public SimpleFileReader<ManifestFileMeta> manifestListReader() {
- return wrapped.manifestListReader();
- }
-
- @Override
- public SimpleFileReader<ManifestEntry> manifestFileReader() {
- return wrapped.manifestFileReader();
- }
-
- @Override
- public SimpleFileReader<IndexManifestEntry> indexManifestFileReader() {
- return wrapped.indexManifestFileReader();
- }
-
@Override
public FileStoreTable copy(TableSchema newTableSchema) {
return new FallbackReadFileStoreTable(
