Uses of Class
io.debezium.pipeline.DataChangeEvent

Packages that use DataChangeEvent

Package	Description
io.debezium.heartbeat
io.debezium.pipeline
io.debezium.pipeline.spi

Uses of DataChangeEvent in io.debezium.heartbeat

Fields in io.debezium.heartbeat with type parameters of type DataChangeEvent

Modifier and Type	Field	Description
private final ChangeEventQueue<DataChangeEvent>	HeartbeatImpl.queue

Method parameters in io.debezium.heartbeat with type arguments of type DataChangeEvent

Modifier and Type	Method	Description
Optional<Heartbeat>	DatabaseHeartbeatFactory.getHeartbeat(CommonConnectorConfig connectorConfig, HeartbeatConnectionProvider connectionProvider, HeartbeatErrorHandler errorHandler, ChangeEventQueue<DataChangeEvent> queue)
default Optional<Heartbeat>	DebeziumHeartbeatFactory.getHeartbeat(CommonConnectorConfig connectorConfig, HeartbeatConnectionProvider connectionProvider, HeartbeatErrorHandler errorHandler, ChangeEventQueue<DataChangeEvent> queue)
default Heartbeat.ScheduledHeartbeat	DebeziumHeartbeatFactory.getScheduledHeartbeat(CommonConnectorConfig connectorConfig, HeartbeatConnectionProvider connectionProvider, HeartbeatErrorHandler errorHandler, ChangeEventQueue<DataChangeEvent> queue)
Heartbeat.ScheduledHeartbeat	HeartbeatFactory.getScheduledHeartbeat(CommonConnectorConfig connectorConfig, HeartbeatConnectionProvider connectionProvider, HeartbeatErrorHandler errorHandler, ChangeEventQueue<DataChangeEvent> queue)	Create a heartbeat instance that can be scheduled with some delay based on CommonConnectorConfig

Constructor parameters in io.debezium.heartbeat with type arguments of type DataChangeEvent

Modifier	Constructor	Description
	HeartbeatImpl(Duration heartbeatInterval, String topicName, String key, SchemaNameAdjuster schemaNameAdjuster, ChangeEventQueue<DataChangeEvent> queue)

Uses of DataChangeEvent in io.debezium.pipeline

Fields in io.debezium.pipeline declared as DataChangeEvent

Modifier and Type	Field	Description
private DataChangeEvent	EventDispatcher.BufferedDataChangeEvent.dataChangeEvent

Fields in io.debezium.pipeline with type parameters of type DataChangeEvent

Modifier and Type	Field	Description
private final ChangeEventQueue<DataChangeEvent>	EventDispatcher.queue

Constructor parameters in io.debezium.pipeline with type arguments of type DataChangeEvent

Modifier	Constructor	Description
	EventDispatcher(CommonConnectorConfig connectorConfig, io.debezium.spi.topic.TopicNamingStrategy<T> topicNamingStrategy, DatabaseSchema<T> schema, ChangeEventQueue<DataChangeEvent> queue, DataCollectionFilters.DataCollectionFilter<T> filter, ChangeEventCreator changeEventCreator, EventDispatcher.InconsistentSchemaHandler<P,T> inconsistentSchemaHandler, Heartbeat.ScheduledHeartbeat heartbeat, SchemaNameAdjuster schemaNameAdjuster, TransactionMonitor transactionMonitor, SignalProcessor<P,?> signalProcessor, DebeziumHeaderProducer debeziumHeaderProducer)
	EventDispatcher(CommonConnectorConfig connectorConfig, io.debezium.spi.topic.TopicNamingStrategy<T> topicNamingStrategy, DatabaseSchema<T> schema, ChangeEventQueue<DataChangeEvent> queue, DataCollectionFilters.DataCollectionFilter<T> filter, ChangeEventCreator changeEventCreator, EventDispatcher.InconsistentSchemaHandler<P,T> inconsistentSchemaHandler, EventMetadataProvider metadataProvider, Heartbeat.ScheduledHeartbeat heartbeat, SchemaNameAdjuster schemaNameAdjuster, SignalProcessor<P,?> signalProcessor, DebeziumHeaderProducer debeziumHeaderProducer)
	EventDispatcher(CommonConnectorConfig connectorConfig, io.debezium.spi.topic.TopicNamingStrategy<T> topicNamingStrategy, DatabaseSchema<T> schema, ChangeEventQueue<DataChangeEvent> queue, DataCollectionFilters.DataCollectionFilter<T> filter, ChangeEventCreator changeEventCreator, EventMetadataProvider metadataProvider, Heartbeat.ScheduledHeartbeat heartbeat, SchemaNameAdjuster schemaNameAdjuster, DebeziumHeaderProducer debeziumHeaderProducer)
	EventDispatcher(CommonConnectorConfig connectorConfig, io.debezium.spi.topic.TopicNamingStrategy<T> topicNamingStrategy, DatabaseSchema<T> schema, ChangeEventQueue<DataChangeEvent> queue, DataCollectionFilters.DataCollectionFilter<T> filter, ChangeEventCreator changeEventCreator, EventMetadataProvider metadataProvider, Heartbeat.ScheduledHeartbeat heartbeat, SchemaNameAdjuster schemaNameAdjuster, SignalProcessor<P,?> signalProcessor, DebeziumHeaderProducer debeziumHeaderProducer)
	EventDispatcher(CommonConnectorConfig connectorConfig, io.debezium.spi.topic.TopicNamingStrategy<T> topicNamingStrategy, DatabaseSchema<T> schema, ChangeEventQueue<DataChangeEvent> queue, DataCollectionFilters.DataCollectionFilter<T> filter, ChangeEventCreator changeEventCreator, EventMetadataProvider metadataProvider, SchemaNameAdjuster schemaNameAdjuster, DebeziumHeaderProducer debeziumHeaderProducer)
	EventDispatcher(CommonConnectorConfig connectorConfig, io.debezium.spi.topic.TopicNamingStrategy<T> topicNamingStrategy, DatabaseSchema<T> schema, ChangeEventQueue<DataChangeEvent> queue, DataCollectionFilters.DataCollectionFilter<T> filter, ChangeEventCreator changeEventCreator, EventMetadataProvider metadataProvider, SchemaNameAdjuster schemaNameAdjuster, SignalProcessor<P,?> signalProcessor, DebeziumHeaderProducer debeziumHeaderProducer)

Uses of DataChangeEvent in io.debezium.pipeline.spi

Methods in io.debezium.pipeline.spi that return DataChangeEvent

Modifier and Type	Method	Description
DataChangeEvent	ChangeEventCreator.createDataChangeEvent(org.apache.kafka.connect.source.SourceRecord sourceRecord)