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

Class MySqlTaskContextImpl

java.lang.Object

io.debezium.connector.common.CdcSourceTaskContext

io.debezium.connector.mysql.MySqlTaskContext

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

public class MySqlTaskContextImpl
extends io.debezium.connector.mysql.MySqlTaskContext

A subclass implementation of MySqlTaskContext which reuses one BinaryLogClient.

Constructor Summary

Constructors

Constructor and Description
MySqlTaskContextImpl(io.debezium.connector.mysql.MySqlConnectorConfig config, io.debezium.connector.mysql.MySqlDatabaseSchema schema, com.github.shyiko.mysql.binlog.BinaryLogClient reusedBinaryLogClient)

Method Summary

Modifier and Type	Method and Description
com.github.shyiko.mysql.binlog.BinaryLogClient	getBinaryLogClient()

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

getSchema, getTopicSelector

Methods inherited from class io.debezium.connector.common.CdcSourceTaskContext

capturedDataCollections, configureLoggingContext, getClock, getConnectorName, getConnectorType, temporaryLoggingContext

Methods inherited from class java.lang.Object

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

Constructor Detail

MySqlTaskContextImpl

public MySqlTaskContextImpl(io.debezium.connector.mysql.MySqlConnectorConfig config,
                            io.debezium.connector.mysql.MySqlDatabaseSchema schema,
                            com.github.shyiko.mysql.binlog.BinaryLogClient reusedBinaryLogClient)

Method Detail

getBinaryLogClient

public com.github.shyiko.mysql.binlog.BinaryLogClient getBinaryLogClient()

Overrides:

getBinaryLogClient in class io.debezium.connector.mysql.MySqlTaskContext