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

Class MySqlSnapshotSplit

java.lang.Object

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

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

All Implemented Interfaces:

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

Direct Known Subclasses:

MySqlSchemalessSnapshotSplit

public class MySqlSnapshotSplit
extends MySqlSplit

The split to describe a split of a MySql table snapshot.

Field Summary

Fields inherited from class org.apache.flink.cdc.connectors.mysql.source.split.MySqlSplit

splitId

Constructor Summary

Constructors

Constructor	Description
MySqlSnapshotSplit(io.debezium.relational.TableId tableId, int chunkId, org.apache.flink.table.types.logical.RowType splitKeyType, Object[] splitStart, Object[] splitEnd, BinlogOffset highWatermark, Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange> tableSchemas)	Create a SnapshotSplit with generating splitId with the given tableId and chunkId.
MySqlSnapshotSplit(io.debezium.relational.TableId tableId, String splitId, org.apache.flink.table.types.logical.RowType splitKeyType, Object[] splitStart, Object[] splitEnd, BinlogOffset highWatermark, Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange> tableSchemas)	This constructor should not be used directly.

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
static int	extractChunkId(String splitId)
static io.debezium.relational.TableId	extractTableId(String splitId)
static String	generateSplitId(io.debezium.relational.TableId tableId, int chunkId)
BinlogOffset	getHighWatermark()
Object[]	getSplitEnd()
org.apache.flink.table.types.logical.RowType	getSplitKeyType()
Object[]	getSplitStart()
io.debezium.relational.TableId	getTableId()
Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange>	getTableSchemas()
int	hashCode()
boolean	isSnapshotReadFinished()
MySqlSchemalessSnapshotSplit	toSchemalessSnapshotSplit()	Casts this split into a MySqlSchemalessSnapshotSplit.
String	toString()

Methods inherited from class org.apache.flink.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

MySqlSnapshotSplit

public MySqlSnapshotSplit(io.debezium.relational.TableId tableId,
                          int chunkId,
                          org.apache.flink.table.types.logical.RowType splitKeyType,
                          Object[] splitStart,
                          Object[] splitEnd,
                          BinlogOffset highWatermark,
                          Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange> tableSchemas)

Create a SnapshotSplit with generating splitId with the given tableId and chunkId.

See Also:

generateSplitId(TableId, int)

MySqlSnapshotSplit

@Internal
public MySqlSnapshotSplit(io.debezium.relational.TableId tableId,
                          String splitId,
                          org.apache.flink.table.types.logical.RowType splitKeyType,
                          Object[] splitStart,
                          Object[] splitEnd,
                          BinlogOffset highWatermark,
                          Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange> tableSchemas)

This constructor should not be used directly. Please use the other constructor. If this constructor must be invoked, please use the same format for the splitId as generateSplitId(TableId, int). Or else the parsing method will fail. See more in extractTableId(String) and extractChunkId(String).

Method Detail

getTableId

public io.debezium.relational.TableId getTableId()

getSplitStart

@Nullable
public Object[] getSplitStart()

getSplitEnd

@Nullable
public Object[] getSplitEnd()

getHighWatermark

@Nullable
public BinlogOffset getHighWatermark()

isSnapshotReadFinished

public boolean isSnapshotReadFinished()

getTableSchemas

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

Specified by:

getTableSchemas in class MySqlSplit

toSchemalessSnapshotSplit

public final MySqlSchemalessSnapshotSplit toSchemalessSnapshotSplit()

Casts this split into a MySqlSchemalessSnapshotSplit.

generateSplitId

public static String generateSplitId(io.debezium.relational.TableId tableId,
                                     int chunkId)

extractTableId

public static io.debezium.relational.TableId extractTableId(String splitId)

extractChunkId

public static int extractChunkId(String splitId)

equals

public boolean equals(Object o)

Overrides:

equals in class MySqlSplit

getSplitKeyType

public org.apache.flink.table.types.logical.RowType getSplitKeyType()

hashCode

public int hashCode()

Overrides:

hashCode in class MySqlSplit

toString

public String toString()

Overrides:

toString in class Object