Package org.apache.iceberg.flink.source.enumerator
-
Interface Summary Interface Description ContinuousSplitPlanner This interface is introduced so that we can plug in different split planner for unit test -
Class Summary Class Description ContinuousIcebergEnumerator ContinuousSplitPlannerImpl IcebergEnumeratorState Enumerator state for checkpointingIcebergEnumeratorStateSerializer StaticIcebergEnumerator One-time split enumeration at the start-up for batch execution