Package org.apache.flink.cdc.connectors.mysql.source.split

Class MySqlSnapshotSplitState

java.lang.Object

org.apache.flink.cdc.connectors.mysql.source.split.MySqlSplitState

org.apache.flink.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 org.apache.flink.cdc.connectors.mysql.source.split.MySqlSplitState

split

Constructor Summary

Constructors

Constructor	Description
MySqlSnapshotSplitState(MySqlSnapshotSplit split)

Method Summary

Modifier and Type	Method	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 org.apache.flink.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