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

Packages that use MySqlSnapshotSplit

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

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

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

Constructor and Description

MySqlSnapshotSplitReadTask(io.debezium.connector.mysql.MySqlConnectorConfig connectorConfig, io.debezium.connector.mysql.MySqlOffsetContext previousOffset, io.debezium.pipeline.source.spi.SnapshotProgressListener snapshotProgressListener, io.debezium.connector.mysql.MySqlDatabaseSchema databaseSchema, io.debezium.connector.mysql.MySqlConnection jdbcConnection, EventDispatcherImpl<io.debezium.relational.TableId> dispatcher, io.debezium.schema.TopicSelector<io.debezium.relational.TableId> topicSelector, io.debezium.util.Clock clock, MySqlSnapshotSplit snapshotSplit)

Uses of MySqlSnapshotSplit in com.ververica.cdc.connectors.mysql.source.assigners

Methods in com.ververica.cdc.connectors.mysql.source.assigners that return types with arguments of type MySqlSnapshotSplit

Modifier and Type	Method and Description
Map<String,MySqlSnapshotSplit>	MySqlSnapshotSplitAssigner.getAssignedSplits()

Uses of MySqlSnapshotSplit in com.ververica.cdc.connectors.mysql.source.assigners.state

Methods in com.ververica.cdc.connectors.mysql.source.assigners.state that return types with arguments of type MySqlSnapshotSplit

Modifier and Type	Method and Description
Map<String,MySqlSnapshotSplit>	SnapshotPendingSplitsState.getAssignedSplits()
List<MySqlSnapshotSplit>	SnapshotPendingSplitsState.getRemainingSplits()

Constructor parameters in com.ververica.cdc.connectors.mysql.source.assigners.state with type arguments of type MySqlSnapshotSplit

Constructor and Description
SnapshotPendingSplitsState(List<io.debezium.relational.TableId> alreadyProcessedTables, List<MySqlSnapshotSplit> remainingSplits, Map<String,MySqlSnapshotSplit> assignedSplits, Map<String,BinlogOffset> splitFinishedOffsets, AssignerStatus assignerStatus, List<io.debezium.relational.TableId> remainingTables, boolean isTableIdCaseSensitive, boolean isRemainingTablesCheckpointed)
SnapshotPendingSplitsState(List<io.debezium.relational.TableId> alreadyProcessedTables, List<MySqlSnapshotSplit> remainingSplits, Map<String,MySqlSnapshotSplit> assignedSplits, Map<String,BinlogOffset> splitFinishedOffsets, AssignerStatus assignerStatus, List<io.debezium.relational.TableId> remainingTables, boolean isTableIdCaseSensitive, boolean isRemainingTablesCheckpointed)

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

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

Modifier and Type	Method and Description
MySqlSnapshotSplit	MySqlSplit.asSnapshotSplit() Casts this split into a MySqlSnapshotSplit.
MySqlSnapshotSplit	MySqlSnapshotSplitState.toMySqlSplit()

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

Constructor and Description
MySqlSnapshotSplitState(MySqlSnapshotSplit split)

Uses of MySqlSnapshotSplit in com.ververica.cdc.connectors.mysql.source.utils

Methods in com.ververica.cdc.connectors.mysql.source.utils with parameters of type MySqlSnapshotSplit

Modifier and Type	Method and Description
static FinishedSnapshotSplitInfo	RecordUtils.getSnapshotSplitInfo(MySqlSnapshotSplit split, org.apache.kafka.connect.source.SourceRecord highWatermark) Return the finished snapshot split information.
static List<org.apache.kafka.connect.source.SourceRecord>	RecordUtils.normalizedSplitRecords(MySqlSnapshotSplit snapshotSplit, List<org.apache.kafka.connect.source.SourceRecord> sourceRecords, io.debezium.util.SchemaNameAdjuster nameAdjuster) Normalize the records of snapshot split which represents the split records state on high watermark.