com.ververica.cdc.connectors.mysql.debezium.dispatcher

Class EventDispatcherImpl<T extends io.debezium.schema.DataCollectionId>

java.lang.Object

io.debezium.pipeline.EventDispatcher<T>

com.ververica.cdc.connectors.mysql.debezium.dispatcher.EventDispatcherImpl<T>

public class EventDispatcherImpl<T extends io.debezium.schema.DataCollectionId>
extends io.debezium.pipeline.EventDispatcher<T>

A subclass implementation of EventDispatcher.

  1. This class shares one ChangeEventQueue between multiple readers.
  2. This class override some methods for dispatching HistoryRecord directly,
     this is useful for downstream to deserialize the HistoryRecord back.
 

Nested Class Summary

Nested classes/interfaces inherited from class io.debezium.pipeline.EventDispatcher

io.debezium.pipeline.EventDispatcher.InconsistentSchemaHandler<T extends io.debezium.schema.DataCollectionId>, io.debezium.pipeline.EventDispatcher.SnapshotReceiver

Field Summary

Fields

Modifier and Type	Field and Description
static String	HISTORY_RECORD_FIELD

Constructor Summary

Constructors

Constructor and Description

EventDispatcherImpl(io.debezium.config.CommonConnectorConfig connectorConfig, io.debezium.schema.TopicSelector<T> topicSelector, io.debezium.schema.DatabaseSchema<T> schema, io.debezium.connector.base.ChangeEventQueue<io.debezium.pipeline.DataChangeEvent> queue, io.debezium.schema.DataCollectionFilters.DataCollectionFilter<T> filter, io.debezium.pipeline.spi.ChangeEventCreator changeEventCreator, io.debezium.pipeline.source.spi.EventMetadataProvider metadataProvider, io.debezium.util.SchemaNameAdjuster schemaNameAdjuster)

Method Summary

Modifier and Type	Method and Description
void	dispatchSchemaChangeEvent(Collection<T> dataCollectionIds, io.debezium.pipeline.spi.SchemaChangeEventEmitter schemaChangeEventEmitter)
void	dispatchSchemaChangeEvent(T dataCollectionId, io.debezium.pipeline.spi.SchemaChangeEventEmitter schemaChangeEventEmitter)
io.debezium.connector.base.ChangeEventQueue<io.debezium.pipeline.DataChangeEvent>	getQueue()

Methods inherited from class io.debezium.pipeline.EventDispatcher

alwaysDispatchHeartbeatEvent, dispatchConnectorEvent, dispatchDataChangeEvent, dispatchHeartbeatEvent, dispatchSnapshotEvent, dispatchTransactionCommittedEvent, dispatchTransactionStartedEvent, errorOnMissingSchema, getHistorizedSchema, getSchema, getSnapshotChangeEventReceiver, heartbeatsEnabled, ignoreMissingSchema, setEventListener

Methods inherited from class java.lang.Object

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

Field Detail

HISTORY_RECORD_FIELD

public static final String HISTORY_RECORD_FIELD

See Also:

Constant Field Values

Constructor Detail

EventDispatcherImpl

public EventDispatcherImpl(io.debezium.config.CommonConnectorConfig connectorConfig,
                           io.debezium.schema.TopicSelector<T> topicSelector,
                           io.debezium.schema.DatabaseSchema<T> schema,
                           io.debezium.connector.base.ChangeEventQueue<io.debezium.pipeline.DataChangeEvent> queue,
                           io.debezium.schema.DataCollectionFilters.DataCollectionFilter<T> filter,
                           io.debezium.pipeline.spi.ChangeEventCreator changeEventCreator,
                           io.debezium.pipeline.source.spi.EventMetadataProvider metadataProvider,
                           io.debezium.util.SchemaNameAdjuster schemaNameAdjuster)

Method Detail

getQueue

public io.debezium.connector.base.ChangeEventQueue<io.debezium.pipeline.DataChangeEvent> getQueue()

dispatchSchemaChangeEvent

public void dispatchSchemaChangeEvent(T dataCollectionId,
                                      io.debezium.pipeline.spi.SchemaChangeEventEmitter schemaChangeEventEmitter)
                               throws InterruptedException

Overrides:

dispatchSchemaChangeEvent in class io.debezium.pipeline.EventDispatcher<T extends io.debezium.schema.DataCollectionId>

Throws:

InterruptedException

dispatchSchemaChangeEvent

public void dispatchSchemaChangeEvent(Collection<T> dataCollectionIds,
                                      io.debezium.pipeline.spi.SchemaChangeEventEmitter schemaChangeEventEmitter)
                               throws InterruptedException

Overrides:

dispatchSchemaChangeEvent in class io.debezium.pipeline.EventDispatcher<T extends io.debezium.schema.DataCollectionId>

Throws:

InterruptedException