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

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

Direct Known Subclasses:

FlussHybridSnapshotLogSplitState, FlussLogSplitState
```
public abstract class FlussSplitState
extends Object
```
Abstract base class for the mutable state of a FlussSplitBase. Concrete subclasses track the reading progress for each split type and convert back to an immutable split on checkpoint.

See Also:

FlussLogSplitState, FlussHybridSnapshotLogSplitState

Field Summary

Fields
Modifier and Type Field Description

protected FlussSplitBase split

Constructor Summary

Constructors
Constructor Description

FlussSplitState(FlussSplitBase split)

Method Summary

All Methods Instance Methods Abstract Methods Concrete Methods
Modifier and Type	Method	Description
`FlussHybridSnapshotLogSplitState`	`asHybridSnapshotLogSplitState()`	Casts this split state into a `FlussHybridSnapshotLogSplitState`.
`FlussLogSplitState`	`asLogSplitState()`	Casts this split state into a `FlussLogSplitState`.
`org.apache.fluss.types.RowType`	`getRowType()`
`Integer`	`getSchemaId()`
`boolean`	`isHybridSnapshotLogSplitState()`	Checks whether this split state is a hybrid snapshot log split state.
`boolean`	`isLogSplitState()`	Checks whether this split state is a log split state.
`abstract FlussSplitBase`	`toFlussSplit()`	Converts this mutable state back to an immutable split for checkpointing.
`void`	`updateSchema(int schemaId, org.apache.fluss.types.RowType rowType)`	Updates the schema tracking with the latest schemaId and corresponding RowType.

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

- Field Detail
  - split
```
protected final FlussSplitBase split
```
- Constructor Detail
  - FlussSplitState
```
public FlussSplitState(FlussSplitBase split)
```
- Method Detail
  - isHybridSnapshotLogSplitState
```
public final boolean isHybridSnapshotLogSplitState()
```
    Checks whether this split state is a hybrid snapshot log split state.
  - isLogSplitState
```
public final boolean isLogSplitState()
```
    Checks whether this split state is a log split state.
  - asHybridSnapshotLogSplitState
```
public final FlussHybridSnapshotLogSplitState asHybridSnapshotLogSplitState()
```
    Casts this split state into a FlussHybridSnapshotLogSplitState.
  - asLogSplitState
```
public final FlussLogSplitState asLogSplitState()
```
    Casts this split state into a FlussLogSplitState.
  - toFlussSplit
```
public abstract FlussSplitBase toFlussSplit()
```
    Converts this mutable state back to an immutable split for checkpointing.
  - getSchemaId
```
@Nullable
public Integer getSchemaId()
```
  - getRowType
```
@Nullable
public org.apache.fluss.types.RowType getRowType()
```
  - updateSchema
```
public void updateSchema(int schemaId,
                         org.apache.fluss.types.RowType rowType)
```
    Updates the schema tracking with the latest schemaId and corresponding RowType. Called by the record emitter when processing records.