Package io.debezium.pipeline

Class EventDispatcher.BufferingSnapshotChangeRecordReceiver

java.lang.Object

io.debezium.pipeline.EventDispatcher.BufferingSnapshotChangeRecordReceiver

All Implemented Interfaces:

EventDispatcher.SnapshotReceiver<P>, ChangeRecordEmitter.Receiver<P>

Enclosing class:

EventDispatcher<P extends Partition,T extends io.debezium.spi.schema.DataCollectionId>

private final class EventDispatcher.BufferingSnapshotChangeRecordReceiver
extends Object
implements EventDispatcher.SnapshotReceiver<P>

Field Summary

Fields

Modifier and Type	Field	Description
private AtomicReference<EventDispatcher.BufferedDataChangeEvent>	bufferedEventRef
private final boolean	threaded

Constructor Summary

Constructors

Constructor	Description
BufferingSnapshotChangeRecordReceiver(boolean threaded)

Method Summary

Modifier and Type	Method	Description
void	changeRecord(P partition, DataCollectionSchema dataCollectionSchema, Envelope.Operation operation, Object key, org.apache.kafka.connect.data.Struct value, OffsetContext offsetContext, org.apache.kafka.connect.header.ConnectHeaders headers)
void	completeSnapshot()

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.spi.ChangeRecordEmitter.Receiver

unchangedEventSkipped

Field Details

bufferedEventRef

private AtomicReference<EventDispatcher.BufferedDataChangeEvent> bufferedEventRef

threaded

private final boolean threaded

Constructor Details

BufferingSnapshotChangeRecordReceiver

BufferingSnapshotChangeRecordReceiver(boolean threaded)

Method Details

changeRecord

public void changeRecord(P partition,
 DataCollectionSchema dataCollectionSchema,
 Envelope.Operation operation,
 Object key,
 org.apache.kafka.connect.data.Struct value,
 OffsetContext offsetContext,
 org.apache.kafka.connect.header.ConnectHeaders headers)
                  throws InterruptedException

Specified by:

changeRecord in interface ChangeRecordEmitter.Receiver<P extends Partition>

Throws:

InterruptedException

completeSnapshot

public void completeSnapshot()
                      throws InterruptedException

Specified by:

completeSnapshot in interface EventDispatcher.SnapshotReceiver<P extends Partition>

Throws:

InterruptedException