Class MySqlSplitState
- java.lang.Object
-
- org.apache.flink.cdc.connectors.mysql.source.split.MySqlSplitState
-
- Direct Known Subclasses:
MySqlBinlogSplitState,MySqlSnapshotSplitState
public abstract class MySqlSplitState extends Object
State of the reader, essentially a mutable version of theMySqlSplit.
-
-
Field Summary
Fields Modifier and Type Field Description protected MySqlSplitsplit
-
Constructor Summary
Constructors Constructor Description MySqlSplitState(MySqlSplit split)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description MySqlBinlogSplitStateasBinlogSplitState()Casts this split state into aMySqlBinlogSplitState.MySqlSnapshotSplitStateasSnapshotSplitState()Casts this split state into aMySqlSnapshotSplitState.booleanisBinlogSplitState()Checks whether this split state is a binlog split state.booleanisSnapshotSplitState()Checks whether this split state is a snapshot split state.abstract MySqlSplittoMySqlSplit()Use the current split state to create a new MySqlSplit.
-
-
-
Field Detail
-
split
protected final MySqlSplit split
-
-
Constructor Detail
-
MySqlSplitState
public MySqlSplitState(MySqlSplit split)
-
-
Method Detail
-
isSnapshotSplitState
public final boolean isSnapshotSplitState()
Checks whether this split state is a snapshot split state.
-
isBinlogSplitState
public final boolean isBinlogSplitState()
Checks whether this split state is a binlog split state.
-
asSnapshotSplitState
public final MySqlSnapshotSplitState asSnapshotSplitState()
Casts this split state into aMySqlSnapshotSplitState.
-
asBinlogSplitState
public final MySqlBinlogSplitState asBinlogSplitState()
Casts this split state into aMySqlBinlogSplitState.
-
toMySqlSplit
public abstract MySqlSplit toMySqlSplit()
Use the current split state to create a new MySqlSplit.
-
-