Class | Description |
---|---|
IcebergSourceSplit | |
IcebergSourceSplitSerializer |
TODO: use Java serialization for now.
|
IcebergSourceSplitState | |
SplitRequestEvent |
We can remove this class once FLINK-21364 is resolved.
|
Enum | Description |
---|---|
IcebergSourceSplitStatus |