Package org.apache.paimon.flink.source.align

Class Summary

Class	Description
AlignedContinuousFileSplitEnumerator	An aligned continuously monitoring enumerator.
AlignedContinuousFileStoreSource	Used to create AlignedSourceReader and AlignedContinuousFileSplitEnumerator.
AlignedSourceReader	The difference with FileStoreSourceReader is that only after the allocated splits are fully consumed, checkpoints will be made and the next batch of splits will be requested.
CheckpointEvent	Event sent from AlignedContinuousFileSplitEnumerator to AlignedSourceReader to notify the checkpointId that is about to be triggered.
PlaceholderSplit	Used as a placeholder for an empty snapshot, indicating that the current snapshot does not contain any Split.