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

Class MySqlBinlogSplit

java.lang.Object

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

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

All Implemented Interfaces:

org.apache.flink.api.connector.source.SourceSplit

public class MySqlBinlogSplit
extends MySqlSplit

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

Field Summary

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

splitId

Constructor Summary

Constructors

Constructor and Description
MySqlBinlogSplit(String splitId, BinlogOffset startingOffset, BinlogOffset endingOffset, List<FinishedSnapshotSplitInfo> finishedSnapshotSplitInfos, Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange> tableSchemas, int totalFinishedSplitSize)
MySqlBinlogSplit(String splitId, BinlogOffset startingOffset, BinlogOffset endingOffset, List<FinishedSnapshotSplitInfo> finishedSnapshotSplitInfos, Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange> tableSchemas, int totalFinishedSplitSize, boolean isSuspended)

Method Summary

Modifier and Type	Method and Description
static MySqlBinlogSplit	appendFinishedSplitInfos(MySqlBinlogSplit binlogSplit, List<FinishedSnapshotSplitInfo> splitInfos)
boolean	equals(Object o)
static MySqlBinlogSplit	fillTableSchemas(MySqlBinlogSplit binlogSplit, Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange> tableSchemas)
BinlogOffset	getEndingOffset()
List<FinishedSnapshotSplitInfo>	getFinishedSnapshotSplitInfos()
BinlogOffset	getStartingOffset()
Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange>	getTableSchemas()
int	getTotalFinishedSplitSize()
int	hashCode()
boolean	isCompletedSplit()
boolean	isSuspended()
static MySqlBinlogSplit	toNormalBinlogSplit(MySqlBinlogSplit suspendedBinlogSplit, int totalFinishedSplitSize)
String	toString()
static MySqlBinlogSplit	toSuspendedBinlogSplit(MySqlBinlogSplit normalBinlogSplit)

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

asBinlogSplit, asSnapshotSplit, isBinlogSplit, isSnapshotSplit, splitId

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

MySqlBinlogSplit

public MySqlBinlogSplit(String splitId,
                        BinlogOffset startingOffset,
                        BinlogOffset endingOffset,
                        List<FinishedSnapshotSplitInfo> finishedSnapshotSplitInfos,
                        Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange> tableSchemas,
                        int totalFinishedSplitSize,
                        boolean isSuspended)

MySqlBinlogSplit

public MySqlBinlogSplit(String splitId,
                        BinlogOffset startingOffset,
                        BinlogOffset endingOffset,
                        List<FinishedSnapshotSplitInfo> finishedSnapshotSplitInfos,
                        Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange> tableSchemas,
                        int totalFinishedSplitSize)

Method Detail

getStartingOffset

public BinlogOffset getStartingOffset()

getEndingOffset

public BinlogOffset getEndingOffset()

getFinishedSnapshotSplitInfos

public List<FinishedSnapshotSplitInfo> getFinishedSnapshotSplitInfos()

getTableSchemas

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

Specified by:

getTableSchemas in class MySqlSplit

getTotalFinishedSplitSize

public int getTotalFinishedSplitSize()

isSuspended

public boolean isSuspended()

isCompletedSplit

public boolean isCompletedSplit()

equals

public boolean equals(Object o)

Overrides:

equals in class MySqlSplit

hashCode

public int hashCode()

Overrides:

hashCode in class MySqlSplit

toString

public String toString()

Overrides:

toString in class Object

appendFinishedSplitInfos

public static MySqlBinlogSplit appendFinishedSplitInfos(MySqlBinlogSplit binlogSplit,
                                                        List<FinishedSnapshotSplitInfo> splitInfos)

fillTableSchemas

public static MySqlBinlogSplit fillTableSchemas(MySqlBinlogSplit binlogSplit,
                                                Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange> tableSchemas)

toNormalBinlogSplit

public static MySqlBinlogSplit toNormalBinlogSplit(MySqlBinlogSplit suspendedBinlogSplit,
                                                   int totalFinishedSplitSize)

toSuspendedBinlogSplit

public static MySqlBinlogSplit toSuspendedBinlogSplit(MySqlBinlogSplit normalBinlogSplit)