Interface ContinuousSplitPlanner

  • All Superinterfaces:
    java.lang.AutoCloseable, java.io.Closeable
    All Known Implementing Classes:
    ContinuousSplitPlannerImpl

    @Internal
    public interface ContinuousSplitPlanner
    extends java.io.Closeable
    This interface is introduced so that we can plug in different split planner for unit test
    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      org.apache.iceberg.flink.source.enumerator.ContinuousEnumerationResult planSplits​(org.apache.iceberg.flink.source.enumerator.IcebergEnumeratorPosition lastPosition)
      Discover the files appended between lastPosition and current table snapshot
      • Methods inherited from interface java.io.Closeable

        close
    • Method Detail

      • planSplits

        org.apache.iceberg.flink.source.enumerator.ContinuousEnumerationResult planSplits​(org.apache.iceberg.flink.source.enumerator.IcebergEnumeratorPosition lastPosition)
        Discover the files appended between lastPosition and current table snapshot