Package org.apache.flink.cdc.connectors.mysql.debezium.task

Class MySqlBinlogSplitReadTask

java.lang.Object

io.debezium.connector.mysql.MySqlStreamingChangeEventSource

org.apache.flink.cdc.connectors.mysql.debezium.task.MySqlBinlogSplitReadTask

All Implemented Interfaces:

io.debezium.pipeline.source.spi.ChangeEventSource, io.debezium.pipeline.source.spi.StreamingChangeEventSource<io.debezium.connector.mysql.MySqlPartition,io.debezium.connector.mysql.MySqlOffsetContext>

public class MySqlBinlogSplitReadTask
extends 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

MySqlStreamingChangeEventSource.BinlogPosition, 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

Description

MySqlBinlogSplitReadTask(io.debezium.connector.mysql.MySqlConnectorConfig connectorConfig, MySqlConnection connection, EventDispatcherImpl<io.debezium.relational.TableId> dispatcher, SignalEventDispatcher signalEventDispatcher, io.debezium.pipeline.ErrorHandler errorHandler, io.debezium.util.Clock clock, io.debezium.connector.mysql.MySqlTaskContext taskContext, io.debezium.connector.mysql.MySqlStreamingChangeEventSourceMetrics metrics, MySqlBinlogSplit binlogSplit, java.util.function.Predicate<com.github.shyiko.mysql.binlog.event.Event> eventFilter)

Method Summary

Modifier and Type	Method	Description
void	execute(io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext context, io.debezium.connector.mysql.MySqlPartition partition, io.debezium.connector.mysql.MySqlOffsetContext offsetContext)
java.util.function.Predicate<com.github.shyiko.mysql.binlog.event.Event>	getEventFilter()
protected void	handleEvent(io.debezium.connector.mysql.MySqlPartition partition, io.debezium.connector.mysql.MySqlOffsetContext offsetContext, 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, executeIteration, init

Constructor Detail

MySqlBinlogSplitReadTask

public MySqlBinlogSplitReadTask(io.debezium.connector.mysql.MySqlConnectorConfig connectorConfig,
                                MySqlConnection connection,
                                EventDispatcherImpl<io.debezium.relational.TableId> dispatcher,
                                SignalEventDispatcher signalEventDispatcher,
                                io.debezium.pipeline.ErrorHandler errorHandler,
                                io.debezium.util.Clock clock,
                                io.debezium.connector.mysql.MySqlTaskContext taskContext,
                                io.debezium.connector.mysql.MySqlStreamingChangeEventSourceMetrics metrics,
                                MySqlBinlogSplit binlogSplit,
                                java.util.function.Predicate<com.github.shyiko.mysql.binlog.event.Event> eventFilter)

Method Detail

execute

public void execute(io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext context,
                    io.debezium.connector.mysql.MySqlPartition partition,
                    io.debezium.connector.mysql.MySqlOffsetContext offsetContext)
             throws InterruptedException

Specified by:

execute in interface io.debezium.pipeline.source.spi.StreamingChangeEventSource<io.debezium.connector.mysql.MySqlPartition,io.debezium.connector.mysql.MySqlOffsetContext>

Overrides:

execute in class MySqlStreamingChangeEventSource

Throws:

InterruptedException

handleEvent

protected void handleEvent(io.debezium.connector.mysql.MySqlPartition partition,
                           io.debezium.connector.mysql.MySqlOffsetContext offsetContext,
                           com.github.shyiko.mysql.binlog.event.Event event)

Overrides:

handleEvent in class MySqlStreamingChangeEventSource

getEventFilter

@VisibleForTesting
public java.util.function.Predicate<com.github.shyiko.mysql.binlog.event.Event> getEventFilter()