Package org.apache.iceberg.flink.source.split
-
Class Summary Class Description IcebergSourceSplit IcebergSourceSplitSerializer TODO: use Java serialization for now.IcebergSourceSplitState SplitRequestEvent We can remove this class once FLINK-21364 is resolved. -
Enum Summary Enum Description IcebergSourceSplitStatus