| Interface | Description |
|---|---|
| ContinuousSplitPlanner |
This interface is introduced so that we can plug in different split planner for unit test
|
| Class | Description |
|---|---|
| ContinuousIcebergEnumerator | |
| ContinuousSplitPlannerImpl | |
| IcebergEnumeratorState |
Enumerator state for checkpointing
|
| IcebergEnumeratorStateSerializer | |
| StaticIcebergEnumerator |
One-time split enumeration at the start-up for batch execution
|