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

Class MySqlSplit

java.lang.Object

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

All Implemented Interfaces:

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

Direct Known Subclasses:

MySqlBinlogSplit, MySqlSnapshotSplit

public abstract class MySqlSplit
extends Object
implements org.apache.flink.api.connector.source.SourceSplit

The split of table comes from a Table that splits by primary key.

Field Summary

Fields

Modifier and Type	Field and Description
protected String	splitId

Constructor Summary

Constructors

Constructor and Description
MySqlSplit(String splitId)

Method Summary

Modifier and Type	Method and Description
MySqlBinlogSplit	asBinlogSplit() Casts this split into a MySqlBinlogSplit.
MySqlSnapshotSplit	asSnapshotSplit() Casts this split into a MySqlSnapshotSplit.
boolean	equals(Object o)
abstract Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange>	getTableSchemas()
int	hashCode()
boolean	isBinlogSplit() Checks whether this split is a binlog split.
boolean	isSnapshotSplit() Checks whether this split is a snapshot split.
String	splitId()

Methods inherited from class java.lang.Object

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

Field Detail

splitId

protected final String splitId

Constructor Detail

MySqlSplit

public MySqlSplit(String splitId)

Method Detail

isSnapshotSplit

public final boolean isSnapshotSplit()

Checks whether this split is a snapshot split.

isBinlogSplit

public final boolean isBinlogSplit()

Checks whether this split is a binlog split.

asSnapshotSplit

public final MySqlSnapshotSplit asSnapshotSplit()

Casts this split into a MySqlSnapshotSplit.

asBinlogSplit

public final MySqlBinlogSplit asBinlogSplit()

Casts this split into a MySqlBinlogSplit.

splitId

public String splitId()

Specified by:

splitId in interface org.apache.flink.api.connector.source.SourceSplit

getTableSchemas

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

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object