Package org.apache.iceberg.flink.source
Class FlinkSplitPlanner
- java.lang.Object
-
- org.apache.iceberg.flink.source.FlinkSplitPlanner
-
@Internal public class FlinkSplitPlanner extends java.lang.Object
-
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static java.util.List<IcebergSourceSplit>
planIcebergSourceSplits(Table table, ScanContext context, java.util.concurrent.ExecutorService workerPool)
This returns splits for the FLIP-27 source
-
-
-
Method Detail
-
planIcebergSourceSplits
public static java.util.List<IcebergSourceSplit> planIcebergSourceSplits(Table table, ScanContext context, java.util.concurrent.ExecutorService workerPool)
This returns splits for the FLIP-27 source
-
-