Class FlinkSplitPlanner


  • @Internal
    public class FlinkSplitPlanner
    extends java.lang.Object
    • 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