feat: Filter splits that do not require compaction

apache · Apr 18, 2024 · b580c76 · b580c76
1 parent d38e86f
commit b580c76
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/...java/org/apache/paimon/flink/source/operator/MultiTablesBatchCompactorSourceFunction.java b/...java/org/apache/paimon/flink/source/operator/MultiTablesBatchCompactorSourceFunction.java
@@ -22,7 +22,11 @@
 import org.apache.paimon.catalog.Identifier;
 import org.apache.paimon.flink.utils.JavaTypeInfo;
 import org.apache.paimon.io.DataFileMeta;
-import org.apache.paimon.table.source.*;
+import org.apache.paimon.table.source.DataSplit;
+import org.apache.paimon.table.source.EndOfScanException;
+import org.apache.paimon.table.source.InnerStreamTableScanImpl;
+import org.apache.paimon.table.source.Split;
+import org.apache.paimon.table.source.StreamTableScan;
 
 import org.apache.flink.api.common.typeinfo.BasicTypeInfo;
 import org.apache.flink.api.common.typeinfo.TypeInformation;