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

Interface ContinuousSplitPlanner

All Superinterfaces:
AutoCloseable, Closeable
All Known Implementing Classes:
ContinuousSplitPlannerImpl
@Internal public interface ContinuousSplitPlanner extends Closeable
This interface is introduced so that we can plug in different split planner for unit test

  • Method Summary

    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 Details

    • 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