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

Packages that use SnapshotChunk

Package	Description
io.debezium.pipeline.source.snapshot.chunked
io.debezium.relational

Uses of SnapshotChunk in io.debezium.pipeline.source.snapshot.chunked

Methods in io.debezium.pipeline.source.snapshot.chunked that return types with arguments of type SnapshotChunk

Modifier and Type	Method	Description
List<SnapshotChunk>	ChunkBoundaryCalculator.createChunks(Table table, List<Object[]> boundaries, int tableOrder, int tableCount, String baseSelectStatement, OptionalLong totalRowCount, Object[] maximumKey)	Create SnapshotChunk objects from calculated boundaries.

Methods in io.debezium.pipeline.source.snapshot.chunked with parameters of type SnapshotChunk

Modifier and Type	Method	Description
String	SnapshotChunkQueryBuilder.buildChunkQuery(SnapshotChunk chunk, List<Column> keyColumns, String baseSelect)	Build a SELECT query for a chunk with appropriate WHERE clause.
PreparedStatement	SnapshotChunkQueryBuilder.prepareChunkStatement(SnapshotChunk chunk, List<Column> keyColumns, String sql)	Prepare a statement and bind chunk boundary parameters.

Uses of SnapshotChunk in io.debezium.relational

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

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)
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.
private void	RelationalSnapshotChangeEventSource.setChunkSnapshotMarker(OffsetContext offset, SnapshotChunk chunk, boolean firstRecordInChunk, boolean lastRecordInChunk)