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

Class MySqlBinlogSplitState

java.lang.Object

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

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

public class MySqlBinlogSplitState
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
MySqlBinlogSplitState(MySqlBinlogSplit split)

Method Summary

Modifier and Type	Method	Description
BinlogOffset	getEndingOffset()
BinlogOffset	getStartingOffset()
Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange>	getTableSchemas()
void	recordSchema(io.debezium.relational.TableId tableId, io.debezium.relational.history.TableChanges.TableChange latestTableChange)
void	setEndingOffset(BinlogOffset endingOffset)
void	setStartingOffset(BinlogOffset startingOffset)
MySqlBinlogSplit	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

MySqlBinlogSplitState

public MySqlBinlogSplitState(MySqlBinlogSplit split)

Method Detail

getStartingOffset

@Nullable
public BinlogOffset getStartingOffset()

setStartingOffset

public void setStartingOffset(@Nullable
                              BinlogOffset startingOffset)

getEndingOffset

@Nullable
public BinlogOffset getEndingOffset()

setEndingOffset

public void setEndingOffset(@Nullable
                            BinlogOffset endingOffset)

getTableSchemas

public Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange> getTableSchemas()

recordSchema

public void recordSchema(io.debezium.relational.TableId tableId,
                         io.debezium.relational.history.TableChanges.TableChange latestTableChange)

toMySqlSplit

public MySqlBinlogSplit 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