Class FlussLogSplitState
- java.lang.Object
-
- org.apache.flink.cdc.connectors.fluss.source.split.FlussSplitState
-
- org.apache.flink.cdc.connectors.fluss.source.split.FlussLogSplitState
-
public class FlussLogSplitState extends FlussSplitState
The state ofFlussLogSplit.
-
-
Field Summary
-
Fields inherited from class org.apache.flink.cdc.connectors.fluss.source.split.FlussSplitState
split
-
-
Constructor Summary
Constructors Constructor Description FlussLogSplitState(FlussLogSplit logSplit)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidsetNextOffset(long nextOffset)FlussLogSplittoFlussSplit()Converts this mutable state back to an immutable split for checkpointing.-
Methods inherited from class org.apache.flink.cdc.connectors.fluss.source.split.FlussSplitState
asHybridSnapshotLogSplitState, asLogSplitState, getRowType, getSchemaId, isHybridSnapshotLogSplitState, isLogSplitState, updateSchema
-
-
-
-
Constructor Detail
-
FlussLogSplitState
public FlussLogSplitState(FlussLogSplit logSplit)
-
-
Method Detail
-
setNextOffset
public void setNextOffset(long nextOffset)
-
toFlussSplit
public FlussLogSplit toFlussSplit()
Description copied from class:FlussSplitStateConverts this mutable state back to an immutable split for checkpointing.- Specified by:
toFlussSplitin classFlussSplitState
-
-