Uses of Class
com.ververica.cdc.connectors.mysql.debezium.dispatcher.EventDispatcherImpl

Packages that use EventDispatcherImpl

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

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

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

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)
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 EventDispatcherImpl in com.ververica.cdc.connectors.mysql.debezium.task.context

Methods in com.ververica.cdc.connectors.mysql.debezium.task.context that return EventDispatcherImpl

Modifier and Type	Method and Description
EventDispatcherImpl<io.debezium.relational.TableId>	StatefulTaskContext.getDispatcher()