FlussHybridSnapshotLogSplitState (flink-cdc-parent 3.8-SNAPSHOT API)

java.lang.Object
- org.apache.flink.cdc.connectors.fluss.source.split.FlussSplitState
- - org.apache.flink.cdc.connectors.fluss.source.split.FlussHybridSnapshotLogSplitState

public class FlussHybridSnapshotLogSplitState
extends FlussSplitState

The state of FlussHybridSnapshotLogSplit.

Field Summary
- Fields inherited from class org.apache.flink.cdc.connectors.fluss.source.split.FlussSplitState
  split

Constructor Summary

Constructors
Constructor Description

FlussHybridSnapshotLogSplitState(FlussHybridSnapshotLogSplit hybridSplit)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`setNextOffset(long nextOffset)`
`void`	`setRecordsToSkip(long recordsToSkip)`
`FlussHybridSnapshotLogSplit`	`toFlussSplit()`	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

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - FlussHybridSnapshotLogSplitState
```
public FlussHybridSnapshotLogSplitState(FlussHybridSnapshotLogSplit hybridSplit)
```
- Method Detail
  - setRecordsToSkip
```
public void setRecordsToSkip(long recordsToSkip)
```
  - setNextOffset
```
public void setNextOffset(long nextOffset)
```
  - toFlussSplit
```
public FlussHybridSnapshotLogSplit toFlussSplit()
```
    Description copied from class: FlussSplitState
    
    Converts this mutable state back to an immutable split for checkpointing.
    
    Specified by:
    
    toFlussSplit in class FlussSplitState