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 betweenlastPosition
and current table snapshot
-