Uses of Interface
io.debezium.pipeline.EventDispatcher.SnapshotReceiver

Packages that use EventDispatcher.SnapshotReceiver

Package	Description
io.debezium.pipeline
io.debezium.relational

Uses of EventDispatcher.SnapshotReceiver in io.debezium.pipeline

Classes in io.debezium.pipeline that implement EventDispatcher.SnapshotReceiver

Modifier and Type	Class	Description
private final class	EventDispatcher.BufferingSnapshotChangeRecordReceiver
private final class	EventDispatcher.IncrementalSnapshotChangeRecordReceiver

Methods in io.debezium.pipeline that return EventDispatcher.SnapshotReceiver

Modifier and Type	Method	Description
EventDispatcher.SnapshotReceiver<P>	EventDispatcher.getIncrementalSnapshotChangeEventReceiver(DataChangeEventListener<P> dataListener)
EventDispatcher.SnapshotReceiver<P>	EventDispatcher.getSnapshotChangeEventReceiver()

Methods in io.debezium.pipeline with parameters of type EventDispatcher.SnapshotReceiver

Modifier and Type	Method	Description
void	EventDispatcher.dispatchSnapshotEvent(P partition, T dataCollectionId, ChangeRecordEmitter<P> changeRecordEmitter, EventDispatcher.SnapshotReceiver<P> receiver)

Uses of EventDispatcher.SnapshotReceiver in io.debezium.relational

Methods in io.debezium.relational with parameters of type EventDispatcher.SnapshotReceiver

Modifier and Type	Method	Description
private void	RelationalSnapshotChangeEventSource.createChunkedDataEvents(ChangeEventSource.ChangeEventSourceContext sourceContext, RelationalSnapshotChangeEventSource.RelationalSnapshotContext<P,O> snapshotContext, Queue<JdbcConnection> connectionPool, Map<io.debezium.spi.schema.DataCollectionId,String> snapshotSelectOverridesByTable, Queue<O> offsets, EventDispatcher.SnapshotReceiver<P> snapshotReceiver)
protected Callable<Void>	RelationalSnapshotChangeEventSource.createDataEventsForChunkedTableCallable(ChangeEventSource.ChangeEventSourceContext sourceContext, RelationalSnapshotChangeEventSource.RelationalSnapshotContext<P,O> snapshotContext, EventDispatcher.SnapshotReceiver<P> snapshotReceiver, SnapshotChunk chunk, Map<TableId,TableChunkProgress> progressMap, SnapshotProgress snapshotProgress, Queue<JdbcConnection> connectionPool, Queue<O> offsets)
protected Callable<Void>	RelationalSnapshotChangeEventSource.createDataEventsForTableCallable(ChangeEventSource.ChangeEventSourceContext sourceContext, RelationalSnapshotChangeEventSource.RelationalSnapshotContext<P,O> snapshotContext, EventDispatcher.SnapshotReceiver<P> snapshotReceiver, Table table, boolean firstTable, boolean lastTable, int tableOrder, int tableCount, String selectStatement, OptionalLong rowCount, Set<TableId> rowCountTablesKeySet, Queue<JdbcConnection> connectionPool, Queue<O> offsets)
private void	RelationalSnapshotChangeEventSource.createLegacyDataEvents(ChangeEventSource.ChangeEventSourceContext sourceContext, RelationalSnapshotChangeEventSource.RelationalSnapshotContext<P,O> snapshotContext, Queue<JdbcConnection> connectionPool, Map<io.debezium.spi.schema.DataCollectionId,String> snapshotSelectOverridesByTable, Queue<O> offsets, EventDispatcher.SnapshotReceiver<P> snapshotReceiver)
protected void	RelationalSnapshotChangeEventSource.doCreateDataEventsForChunk(ChangeEventSource.ChangeEventSourceContext sourceContext, RelationalSnapshotChangeEventSource.RelationalSnapshotContext<P,O> snapshotContext, O offset, EventDispatcher.SnapshotReceiver<P> snapshotReceiver, SnapshotChunk chunk, Map<TableId,TableChunkProgress> progressMap, SnapshotProgress snapshotProgress, JdbcConnection jdbcConnection)
protected void	RelationalSnapshotChangeEventSource.doCreateDataEventsForTable(ChangeEventSource.ChangeEventSourceContext sourceContext, RelationalSnapshotChangeEventSource.RelationalSnapshotContext<P,O> snapshotContext, O offset, EventDispatcher.SnapshotReceiver<P> snapshotReceiver, Table table, boolean firstTable, boolean lastTable, int tableOrder, int tableCount, String selectStatement, OptionalLong rowCount, Set<TableId> rowCountTablesKeySet, JdbcConnection jdbcConnection)
private void	RelationalSnapshotChangeEventSource.emitRecordWithCoordination(RelationalSnapshotChangeEventSource.RelationalSnapshotContext<P,O> snapshotContext, O offset, EventDispatcher.SnapshotReceiver<P> snapshotReceiver, SnapshotChunk chunk, TableChunkProgress progress, SnapshotProgress snapshotProgress, TableId tableId, Object[] row, Instant sourceTableSnapshotTimestamp, boolean isFirstRecord, boolean isLastRecord)	Emits a record with proper coordination to ensure correct snapshot marker ordering.