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
|