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

Class MySqlSnapshotSplitState

java.lang.Object

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

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

public class MySqlSnapshotSplitState
extends MySqlSplitState

The state of split to describe the binlog of MySql table(s).

Field Summary

Fields inherited from class com.ververica.cdc.connectors.mysql.source.split.MySqlSplitState

split

Constructor Summary

Constructors

Constructor and Description
MySqlSnapshotSplitState(MySqlSnapshotSplit split)

Method Summary

Modifier and Type	Method and Description
BinlogOffset	getHighWatermark()
void	setHighWatermark(BinlogOffset highWatermark)
MySqlSnapshotSplit	toMySqlSplit() Use the current split state to create a new MySqlSplit.
String	toString()

Methods inherited from class com.ververica.cdc.connectors.mysql.source.split.MySqlSplitState

asBinlogSplitState, asSnapshotSplitState, isBinlogSplitState, isSnapshotSplitState

Methods inherited from class java.lang.Object

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

Constructor Detail

MySqlSnapshotSplitState

public MySqlSnapshotSplitState(MySqlSnapshotSplit split)

Method Detail

getHighWatermark

@Nullable
public BinlogOffset getHighWatermark()

setHighWatermark

public void setHighWatermark(@Nullable
                             BinlogOffset highWatermark)

toMySqlSplit

public MySqlSnapshotSplit toMySqlSplit()

Description copied from class: MySqlSplitState

Use the current split state to create a new MySqlSplit.

Specified by:

toMySqlSplit in class MySqlSplitState

toString

public String toString()

Overrides:

toString in class Object