Uses of Package
org.apache.flink.cdc.connectors.fluss.source.split
-
Classes in org.apache.flink.cdc.connectors.fluss.source.split used by org.apache.flink.cdc.connectors.fluss.source Class Description FlussSplitBase Abstract base class for all Fluss source splits. -
Classes in org.apache.flink.cdc.connectors.fluss.source.split used by org.apache.flink.cdc.connectors.fluss.source.enumerator Class Description FlussSplitBase Abstract base class for all Fluss source splits. -
Classes in org.apache.flink.cdc.connectors.fluss.source.split used by org.apache.flink.cdc.connectors.fluss.source.reader Class Description FlussSplitBase Abstract base class for all Fluss source splits.FlussSplitState Abstract base class for the mutable state of aFlussSplitBase. -
Classes in org.apache.flink.cdc.connectors.fluss.source.split used by org.apache.flink.cdc.connectors.fluss.source.split 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 ofFlussHybridSnapshotLogSplit.FlussLogSplit A split that reads change log records from a Fluss table bucket starting at a given offset.FlussLogSplitState The state ofFlussLogSplit.FlussSnapshotSplit A split that reads a bounded KV snapshot from a Fluss table bucket.FlussSplitBase Abstract base class for all Fluss source splits.FlussSplitState Abstract base class for the mutable state of aFlussSplitBase.