com.ververica.cdc.connectors.mysql.source.split

Class MySqlSplitState

java.lang.Object

com.ververica.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 the MySqlSplit.

Field Summary

Fields

Modifier and Type	Field and Description
protected MySqlSplit	split

Constructor Summary

Constructors

Constructor and Description
MySqlSplitState(MySqlSplit split)

Method Summary

Modifier and Type	Method and Description
MySqlBinlogSplitState	asBinlogSplitState() Casts this split state into a MySqlBinlogSplitState.
MySqlSnapshotSplitState	asSnapshotSplitState() Casts this split state into a MySqlSnapshotSplitState.
boolean	isBinlogSplitState() Checks whether this split state is a binlog split state.
boolean	isSnapshotSplitState() Checks whether this split state is a snapshot split state.
abstract MySqlSplit	toMySqlSplit() Use the current split state to create a new MySqlSplit.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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 a MySqlSnapshotSplitState.

asBinlogSplitState

public final MySqlBinlogSplitState asBinlogSplitState()

Casts this split state into a MySqlBinlogSplitState.

toMySqlSplit

public abstract MySqlSplit toMySqlSplit()

Use the current split state to create a new MySqlSplit.