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

Class MySqlBinlogSplitReadTask

java.lang.Object

io.debezium.connector.mysql.MySqlStreamingChangeEventSource

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

All Implemented Interfaces:

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

public class MySqlBinlogSplitReadTask
extends io.debezium.connector.mysql.MySqlStreamingChangeEventSource

Task to read all binlog for table and also supports read bounded (from lowWatermark to highWatermark) binlog.

Nested Class Summary

Nested classes/interfaces inherited from class io.debezium.connector.mysql.MySqlStreamingChangeEventSource

io.debezium.connector.mysql.MySqlStreamingChangeEventSource.BinlogPosition, io.debezium.connector.mysql.MySqlStreamingChangeEventSource.ReaderThreadLifecycleListener

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

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

Constructor Summary

Constructors

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)

Method Summary

Modifier and Type	Method and Description
void	execute(io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext context)
protected void	handleEvent(com.github.shyiko.mysql.binlog.event.Event event)

Methods inherited from class io.debezium.connector.mysql.MySqlStreamingChangeEventSource

filterGtidSet, handleDelete, handleGtidEvent, handleInsert, handleQueryEvent, handleRotateLogsEvent, handleRowsQuery, handleServerHeartbeat, handleServerIncident, handleServerStop, handleUpdate, handleUpdateTableMetadata, ignoreEvent, logEvent, onEvent, prepareTransaction, unwrapData, viewChange, wrap

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.debezium.pipeline.source.spi.StreamingChangeEventSource

commitOffset

Constructor Detail

MySqlBinlogSplitReadTask

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

Method Detail

execute

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

Specified by:

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

Overrides:

execute in class io.debezium.connector.mysql.MySqlStreamingChangeEventSource

Throws:

InterruptedException

handleEvent

protected void handleEvent(com.github.shyiko.mysql.binlog.event.Event event)

Overrides:

handleEvent in class io.debezium.connector.mysql.MySqlStreamingChangeEventSource