Class 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, org.apache.iceberg.flink.source.ScanContext context)
      This returns splits for the FLIP-27 source
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Method Detail

      • planIcebergSourceSplits

        public static java.util.List<IcebergSourceSplit> planIcebergSourceSplits​(Table table,
                                                                                 org.apache.iceberg.flink.source.ScanContext context)
        This returns splits for the FLIP-27 source