@Internal public class ContinuousSplitPlannerImpl extends java.lang.Object implements ContinuousSplitPlanner
Constructor and Description |
---|
ContinuousSplitPlannerImpl(TableLoader tableLoader,
ScanContext scanContext,
java.lang.String threadName) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
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 |
public ContinuousSplitPlannerImpl(TableLoader tableLoader, ScanContext scanContext, java.lang.String threadName)
tableLoader
- A cloned tableLoader.threadName
- thread name prefix for worker pool to run the split planning. If null, a
shared worker pool will be used.public void close() throws java.io.IOException
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
java.io.IOException
public org.apache.iceberg.flink.source.enumerator.ContinuousEnumerationResult planSplits(org.apache.iceberg.flink.source.enumerator.IcebergEnumeratorPosition lastPosition)
ContinuousSplitPlanner
lastPosition
and current table snapshotplanSplits
in interface ContinuousSplitPlanner