Uses of Class
io.debezium.pipeline.source.snapshot.chunked.TableChunkProgress

Packages that use TableChunkProgress

Package	Description
io.debezium.relational

Uses of TableChunkProgress in io.debezium.relational

Methods in io.debezium.relational with parameters of type TableChunkProgress

Modifier and Type	Method	Description
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.
private void	RelationalSnapshotChangeEventSource.handleEmptyChunkCoordination(SnapshotChunk chunk, TableChunkProgress progress, SnapshotProgress snapshotProgress)	Handles coordination for empty chunks to ensure latches are properly signaled.

Method parameters in io.debezium.relational with type arguments of type TableChunkProgress

Modifier and Type	Method	Description
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 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)