@Internal
public interface ContinuousSplitPlanner
extends java.io.Closeable
Modifier and Type | Method and 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 |