diff --git a/paimon-core/src/main/java/org/apache/paimon/AppendOnlyFileStore.java b/paimon-core/src/main/java/org/apache/paimon/AppendOnlyFileStore.java index feeaa180628da..a4f8766264f8e 100644 --- a/paimon-core/src/main/java/org/apache/paimon/AppendOnlyFileStore.java +++ b/paimon-core/src/main/java/org/apache/paimon/AppendOnlyFileStore.java @@ -39,7 +39,6 @@ import static org.apache.paimon.predicate.PredicateBuilder.and; import static org.apache.paimon.predicate.PredicateBuilder.pickTransformFieldMapping; import static org.apache.paimon.predicate.PredicateBuilder.splitAnd; -import static org.apache.paimon.utils.BranchManager.DEFAULT_MAIN_BRANCH; /** {@link FileStore} for reading and writing {@link InternalRow}. */ public class AppendOnlyFileStore extends AbstractFileStore { @@ -71,11 +70,7 @@ public BucketMode bucketMode() { @Override public AppendOnlyFileStoreScan newScan() { - return newScan(options.branch()); - } - - public AppendOnlyFileStoreScan newScan(String branchName) { - return newScan(false, branchName); + return newScan(); } @Override @@ -105,12 +100,12 @@ public AppendOnlyFileStoreWrite newWrite( rowType, pathFactory(), snapshotManager(), - newScan(true, DEFAULT_MAIN_BRANCH).withManifestCacheFilter(manifestFilter), + newScan(true).withManifestCacheFilter(manifestFilter), options, tableName); } - private AppendOnlyFileStoreScan newScan(boolean forWrite, String branchName) { + private AppendOnlyFileStoreScan newScan(boolean forWrite) { ScanBucketFilter bucketFilter = new ScanBucketFilter(bucketKeyType) { @Override diff --git a/paimon-core/src/main/java/org/apache/paimon/KeyValueFileStore.java b/paimon-core/src/main/java/org/apache/paimon/KeyValueFileStore.java index 4483c027e96e4..4527e6de9d784 100644 --- a/paimon-core/src/main/java/org/apache/paimon/KeyValueFileStore.java +++ b/paimon-core/src/main/java/org/apache/paimon/KeyValueFileStore.java @@ -39,7 +39,6 @@ import org.apache.paimon.table.BucketMode; import org.apache.paimon.table.CatalogEnvironment; import org.apache.paimon.types.RowType; -import org.apache.paimon.utils.BranchManager; import org.apache.paimon.utils.FileStorePathFactory; import org.apache.paimon.utils.KeyComparatorSupplier; import org.apache.paimon.utils.UserDefinedSeqComparator; @@ -111,7 +110,7 @@ public BucketMode bucketMode() { @Override public KeyValueFileStoreScan newScan() { - return newScan(false, BranchManager.DEFAULT_MAIN_BRANCH); + return newScan(false); } @Override @@ -169,8 +168,7 @@ public KeyValueFileStoreWrite newWrite(String commitUser, ManifestCacheFilter ma pathFactory(), format2PathFactory(), snapshotManager(), - newScan(true, BranchManager.DEFAULT_MAIN_BRANCH) - .withManifestCacheFilter(manifestFilter), + newScan(true).withManifestCacheFilter(manifestFilter), indexFactory, deletionVectorsMaintainerFactory, options, @@ -194,7 +192,7 @@ private Map format2PathFactory() { return pathFactoryMap; } - private KeyValueFileStoreScan newScan(boolean forWrite, String branchName) { + private KeyValueFileStoreScan newScan(boolean forWrite) { ScanBucketFilter bucketFilter = new ScanBucketFilter(bucketKeyType) { @Override @@ -225,7 +223,6 @@ public void pushdown(Predicate keyFilter) { options.bucket(), forWrite, options.scanManifestParallelism(), - branchName, options.deletionVectorsEnabled(), options.mergeEngine()); } diff --git a/paimon-core/src/main/java/org/apache/paimon/operation/KeyValueFileStoreScan.java b/paimon-core/src/main/java/org/apache/paimon/operation/KeyValueFileStoreScan.java index 09a82313e364f..83da1221ad9e4 100644 --- a/paimon-core/src/main/java/org/apache/paimon/operation/KeyValueFileStoreScan.java +++ b/paimon-core/src/main/java/org/apache/paimon/operation/KeyValueFileStoreScan.java @@ -62,7 +62,6 @@ public KeyValueFileStoreScan( int numOfBuckets, boolean checkNumOfBuckets, Integer scanManifestParallelism, - String branchName, boolean deletionVectorsEnabled, MergeEngine mergeEngine) { super(