com.ververica.cdc.connectors.mysql.debezium.task

Class MySqlSnapshotSplitReadTask

java.lang.Object

io.debezium.pipeline.source.AbstractSnapshotChangeEventSource

com.ververica.cdc.connectors.mysql.debezium.task.MySqlSnapshotSplitReadTask

All Implemented Interfaces:

io.debezium.pipeline.source.spi.ChangeEventSource, io.debezium.pipeline.source.spi.SnapshotChangeEventSource

public class MySqlSnapshotSplitReadTask
extends io.debezium.pipeline.source.AbstractSnapshotChangeEventSource

Task to read snapshot split of table.

Nested Class Summary

Nested classes/interfaces inherited from class io.debezium.pipeline.source.AbstractSnapshotChangeEventSource

io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshotContext, io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshottingTask

Nested classes/interfaces inherited from interface io.debezium.pipeline.source.spi.ChangeEventSource

io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext

Field Summary

Fields inherited from class io.debezium.pipeline.source.AbstractSnapshotChangeEventSource

previousOffset

Constructor Summary

Constructors

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)

Method Summary

Modifier and Type	Method and Description
protected io.debezium.pipeline.spi.SnapshotResult	doExecute(io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext context, io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshotContext snapshotContext, io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshottingTask snapshottingTask)
io.debezium.pipeline.spi.SnapshotResult	execute(io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext context)
protected io.debezium.pipeline.spi.ChangeRecordEmitter	getChangeRecordEmitter(io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshotContext snapshotContext, io.debezium.relational.TableId tableId, Object[] row)
protected io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshottingTask	getSnapshottingTask(io.debezium.pipeline.spi.OffsetContext previousOffset)
protected io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshotContext	prepare(io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext changeEventSourceContext)

Methods inherited from class io.debezium.pipeline.source.AbstractSnapshotChangeEventSource

complete, delaySnapshotIfNeeded, determineDataCollectionsToBeSnapshotted

Methods inherited from class java.lang.Object

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

Constructor Detail

MySqlSnapshotSplitReadTask

public 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)

Method Detail

execute

public io.debezium.pipeline.spi.SnapshotResult execute(io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext context)
                                                throws InterruptedException

Specified by:

execute in interface io.debezium.pipeline.source.spi.SnapshotChangeEventSource

Overrides:

execute in class io.debezium.pipeline.source.AbstractSnapshotChangeEventSource

Throws:

InterruptedException

doExecute

protected io.debezium.pipeline.spi.SnapshotResult doExecute(io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext context,
                                                            io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshotContext snapshotContext,
                                                            io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshottingTask snapshottingTask)
                                                     throws Exception

Specified by:

doExecute in class io.debezium.pipeline.source.AbstractSnapshotChangeEventSource

Throws:

Exception

getSnapshottingTask

protected io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshottingTask getSnapshottingTask(io.debezium.pipeline.spi.OffsetContext previousOffset)

Specified by:

getSnapshottingTask in class io.debezium.pipeline.source.AbstractSnapshotChangeEventSource

prepare

protected io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshotContext prepare(io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext changeEventSourceContext)
                                                                                         throws Exception

Specified by:

prepare in class io.debezium.pipeline.source.AbstractSnapshotChangeEventSource

Throws:

Exception

getChangeRecordEmitter

protected io.debezium.pipeline.spi.ChangeRecordEmitter getChangeRecordEmitter(io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshotContext snapshotContext,
                                                                              io.debezium.relational.TableId tableId,
                                                                              Object[] row)