Package org.apache.flink.cdc.connectors.fluss.source.split

Class Summary

Class	Description
FlussHybridSnapshotLogSplit	A split that first reads a full KV snapshot from a Fluss table bucket, then switches to reading change log from the snapshot's log offset.
FlussHybridSnapshotLogSplitState	The state of FlussHybridSnapshotLogSplit.
FlussLogSplit	A split that reads change log records from a Fluss table bucket starting at a given offset.
FlussLogSplitState	The state of FlussLogSplit.
FlussSnapshotSplit	A split that reads a bounded KV snapshot from a Fluss table bucket.
FlussSplitBase	Abstract base class for all Fluss source splits.
FlussSplitSerializer	Serializer for FlussSplitBase and its subclasses.
FlussSplitState	Abstract base class for the mutable state of a FlussSplitBase.