File tree Expand file tree Collapse file tree 5 files changed +4
-6
lines changed
paimon-core/src/test/java/org/apache/paimon
paimon-flink/paimon-flink-common/src/test/java/org/apache/paimon/flink
paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/procedure Expand file tree Collapse file tree 5 files changed +4
-6
lines changed Original file line number Diff line number Diff line change 2525
2626import org .junit .jupiter .api .Test ;
2727
28- import static org .apache .paimon .utils .FileSystemBranchManager .DEFAULT_MAIN_BRANCH ;
28+ import static org .apache .paimon .utils .BranchManager .DEFAULT_MAIN_BRANCH ;
2929import static org .assertj .core .api .Assertions .assertThat ;
3030
3131/** Test for snapshots. */
Original file line number Diff line number Diff line change 4444
4545import static org .apache .paimon .SnapshotTest .newChangelogManager ;
4646import static org .apache .paimon .SnapshotTest .newSnapshotManager ;
47- import static org .apache .paimon .utils .FileSystemBranchManager .DEFAULT_MAIN_BRANCH ;
47+ import static org .apache .paimon .utils .BranchManager .DEFAULT_MAIN_BRANCH ;
4848import static org .assertj .core .api .Assertions .assertThat ;
4949import static org .assertj .core .api .Assertions .fail ;
5050import static org .junit .jupiter .api .Assertions .assertDoesNotThrow ;
Original file line number Diff line number Diff line change 3333import org .apache .paimon .table .FileStoreTable ;
3434import org .apache .paimon .table .FileStoreTableFactory ;
3535import org .apache .paimon .utils .BlockingIterator ;
36+ import org .apache .paimon .utils .BranchManager ;
3637import org .apache .paimon .utils .FailingFileIO ;
37- import org .apache .paimon .utils .FileSystemBranchManager ;
3838
3939import org .apache .flink .api .common .eventtime .WatermarkStrategy ;
4040import org .apache .flink .api .common .functions .MapFunction ;
@@ -139,7 +139,7 @@ public FileStoreITCase(boolean isBatch) {
139139
140140 @ BeforeAll
141141 public static void before () {
142- branch = FileSystemBranchManager .DEFAULT_MAIN_BRANCH ;
142+ branch = BranchManager .DEFAULT_MAIN_BRANCH ;
143143 }
144144
145145 @ Parameters (name = "isBatch-{0}" )
Original file line number Diff line number Diff line change 1919package org .apache .paimon .spark .procedure
2020
2121import org .apache .paimon .spark .PaimonSparkTestBase
22- import org .apache .paimon .utils .FileSystemBranchManager
2322
2423import org .apache .spark .sql .{Dataset , Row }
2524import org .apache .spark .sql .execution .streaming .MemoryStream
Original file line number Diff line number Diff line change 1919package org .apache .paimon .spark .procedure
2020
2121import org .apache .paimon .spark .PaimonSparkTestBase
22- import org .apache .paimon .utils .FileSystemBranchManager
2322
2423import org .apache .spark .sql .{Dataset , Row }
2524import org .apache .spark .sql .execution .streaming .MemoryStream
You can’t perform that action at this time.
0 commit comments