Uses of Class
com.ververica.cdc.connectors.mysql.source.split.MySqlBinlogSplit

Packages that use MySqlBinlogSplit

Package	Description
com.ververica.cdc.connectors.mysql.debezium.task
com.ververica.cdc.connectors.mysql.source.split

Uses of MySqlBinlogSplit in com.ververica.cdc.connectors.mysql.debezium.task

Constructors in com.ververica.cdc.connectors.mysql.debezium.task with parameters of type MySqlBinlogSplit

Constructor and Description

MySqlBinlogSplitReadTask(io.debezium.connector.mysql.MySqlConnectorConfig connectorConfig, io.debezium.connector.mysql.MySqlOffsetContext offsetContext, io.debezium.connector.mysql.MySqlConnection connection, EventDispatcherImpl<io.debezium.relational.TableId> dispatcher, io.debezium.pipeline.ErrorHandler errorHandler, io.debezium.util.Clock clock, io.debezium.connector.mysql.MySqlTaskContext taskContext, io.debezium.connector.mysql.MySqlStreamingChangeEventSourceMetrics metrics, String topic, MySqlBinlogSplit binlogSplit)

Uses of MySqlBinlogSplit in com.ververica.cdc.connectors.mysql.source.split

Methods in com.ververica.cdc.connectors.mysql.source.split that return MySqlBinlogSplit

Modifier and Type	Method and Description
static MySqlBinlogSplit	MySqlBinlogSplit.appendFinishedSplitInfos(MySqlBinlogSplit binlogSplit, List<FinishedSnapshotSplitInfo> splitInfos)
MySqlBinlogSplit	MySqlSplit.asBinlogSplit() Casts this split into a MySqlBinlogSplit.
static MySqlBinlogSplit	MySqlBinlogSplit.fillTableSchemas(MySqlBinlogSplit binlogSplit, Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange> tableSchemas)
MySqlBinlogSplit	MySqlBinlogSplitState.toMySqlSplit()
static MySqlBinlogSplit	MySqlBinlogSplit.toNormalBinlogSplit(MySqlBinlogSplit suspendedBinlogSplit, int totalFinishedSplitSize)
static MySqlBinlogSplit	MySqlBinlogSplit.toSuspendedBinlogSplit(MySqlBinlogSplit normalBinlogSplit)

Methods in com.ververica.cdc.connectors.mysql.source.split with parameters of type MySqlBinlogSplit

Modifier and Type	Method and Description
static MySqlBinlogSplit	MySqlBinlogSplit.appendFinishedSplitInfos(MySqlBinlogSplit binlogSplit, List<FinishedSnapshotSplitInfo> splitInfos)
static MySqlBinlogSplit	MySqlBinlogSplit.fillTableSchemas(MySqlBinlogSplit binlogSplit, Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange> tableSchemas)
static MySqlBinlogSplit	MySqlBinlogSplit.toNormalBinlogSplit(MySqlBinlogSplit suspendedBinlogSplit, int totalFinishedSplitSize)
static MySqlBinlogSplit	MySqlBinlogSplit.toSuspendedBinlogSplit(MySqlBinlogSplit normalBinlogSplit)

Constructors in com.ververica.cdc.connectors.mysql.source.split with parameters of type MySqlBinlogSplit

Constructor and Description
MySqlBinlogSplitState(MySqlBinlogSplit split)