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

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

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