Package org.apache.iceberg.flink.source.enumerator

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