Package io.debezium.pipeline.source.snapshot.incremental
package io.debezium.pipeline.source.snapshot.incremental
-
ClassDescriptionAbstractChunkQueryBuilder<T extends io.debezium.spi.schema.DataCollectionId>Base class for building queries for reading incremental snapshot chunks from a table.AbstractIncrementalSnapshotChangeEventSource<P extends Partition,
T extends io.debezium.spi.schema.DataCollectionId> An incremental snapshot change event source that emits events from a DB log interleaved with snapshot events.A class describing current state of incremental snapshotChunkQueryBuilder<T extends io.debezium.spi.schema.DataCollectionId>Builds queries for reading incremental snapshot chunks from a table.A class describing CollectionId for incremental snapshotDefaultChunkQueryBuilder<T extends io.debezium.spi.schema.DataCollectionId>Builds queries for reading incremental snapshot chunks from a table using ANSI standard SQL queries.IncrementalSnapshotChangeEventSource<P extends Partition,T extends io.debezium.spi.schema.DataCollectionId> A Contract tPhysicalRowIdentifierChunkQueryBuilder<T extends io.debezium.spi.schema.DataCollectionId>Chunk query builder that injects a hidden physical row identifier (e.g.RowValueConstructorChunkQueryBuilder<T extends io.debezium.spi.schema.DataCollectionId>Builds queries for reading incremental snapshot chunks from a table using row value constructors.SignalBasedIncrementalSnapshotChangeEventSource<P extends Partition,T extends io.debezium.spi.schema.DataCollectionId> A class describing current state of incremental snapshotSignal metadata for the incremental snapshotting