Uses of Class
io.debezium.pipeline.spi.Offsets

Packages that use Offsets

Package	Description
io.debezium.connector.common
io.debezium.pipeline
io.debezium.pipeline.notification
io.debezium.pipeline.notification.channels
io.debezium.pipeline.signal
io.debezium.pipeline.source
io.debezium.pipeline.spi
io.debezium.relational
io.debezium.relational.history
io.debezium.schema

Uses of Offsets in io.debezium.connector.common

Methods in io.debezium.connector.common that return Offsets

Modifier and Type	Method	Description
protected Offsets<P,O>	BaseSourceTask.getPreviousOffsets(Partition.Provider<P> provider, OffsetContext.Loader<O> loader)	Loads the connector's persistent offsets (if present) via the given loader.

Methods in io.debezium.connector.common with parameters of type Offsets

Modifier and Type	Method	Description
protected void	BaseSourceTask.validateSchemaHistory(CommonConnectorConfig config, LogPositionValidator logPositionValidator, Offsets<P,O> previousOffsets, DatabaseSchema schema, io.debezium.spi.snapshot.Snapshotter snapshotter)

Uses of Offsets in io.debezium.pipeline

Fields in io.debezium.pipeline declared as Offsets

Modifier and Type	Field	Description
protected final Offsets<P,O>	ChangeEventSourceCoordinator.previousOffsets	Waiting period for the polling loop to finish.

Methods in io.debezium.pipeline with parameters of type Offsets

Modifier and Type	Method	Description
protected void	ChangeEventSourceCoordinator.executeChangeEventSources(CdcSourceTaskContext taskContext, SnapshotChangeEventSource<P,O> snapshotSource, Offsets<P,O> previousOffsets, AtomicReference<LoggingContext.PreviousContext> previousLogContext, ChangeEventSource.ChangeEventSourceContext context)
Optional<SignalProcessor<P,O>>	ChangeEventSourceCoordinator.getSignalProcessor(Offsets<P,O> previousOffset)

Constructors in io.debezium.pipeline with parameters of type Offsets

Modifier	Constructor	Description
	ChangeEventSourceCoordinator(Offsets<P,O> previousOffsets, ErrorHandler errorHandler, Class<? extends org.apache.kafka.connect.source.SourceConnector> connectorType, CommonConnectorConfig connectorConfig, ChangeEventSourceFactory<P,O> changeEventSourceFactory, ChangeEventSourceMetricsFactory<P> changeEventSourceMetricsFactory, EventDispatcher<P,?> eventDispatcher, DatabaseSchema<?> schema, SignalProcessor<P,O> signalProcessor, NotificationService<P,O> notificationService, SnapshotterService snapshotterService)

Uses of Offsets in io.debezium.pipeline.notification

Methods in io.debezium.pipeline.notification with parameters of type Offsets

Modifier and Type	Method	Description
void	NotificationService.notify(Notification notification, Offsets<P,? extends OffsetContext> offsets)	This method permits to send a notification together with offsets.

Uses of Offsets in io.debezium.pipeline.notification.channels

Methods in io.debezium.pipeline.notification.channels with parameters of type Offsets

Modifier and Type	Method	Description
<P extends Partition, O extends OffsetContext> void	ConnectChannel.send(Notification notification, Offsets<P,O> offsets)
<P extends Partition, O extends OffsetContext> void	SinkNotificationChannel.send(Notification notification, Offsets<P,O> offsets)

Uses of Offsets in io.debezium.pipeline.signal

Methods in io.debezium.pipeline.signal that return Offsets

Modifier and Type	Method	Description
private Offsets<P,O>	SignalProcessor.getOffsets(P knownPartition, Document jsonData)

Methods in io.debezium.pipeline.signal with parameters of type Offsets

Modifier and Type	Method	Description
void	SignalProcessor.setContext(Offsets<P,O> offsets)

Constructors in io.debezium.pipeline.signal with parameters of type Offsets

Modifier	Constructor	Description
	SignalProcessor(Class<? extends org.apache.kafka.connect.source.SourceConnector> connector, CommonConnectorConfig config, Map<String,SignalAction<P>> signalActions, List<SignalChannelReader> signalChannelReaders, DocumentReader documentReader, Offsets<P,O> previousOffsets)

Uses of Offsets in io.debezium.pipeline.source

Methods in io.debezium.pipeline.source that return Offsets

Modifier and Type	Method	Description
protected Offsets<P,OffsetContext>	AbstractSnapshotChangeEventSource.getOffsets(AbstractSnapshotChangeEventSource.SnapshotContext<P,O> ctx, O previousOffset, SnapshottingTask snapshottingTask)

Uses of Offsets in io.debezium.pipeline.spi

Methods in io.debezium.pipeline.spi that return Offsets

Modifier and Type	Method	Description
static <P extends Partition, O extends OffsetContext> Offsets<P,O>	Offsets.of(Map<P,O> offsets)
static <P extends Partition, O extends OffsetContext> Offsets<P,O>	Offsets.of(P partition, O position)

Uses of Offsets in io.debezium.relational

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

Modifier and Type	Method	Description
void	HistorizedRelationalDatabaseSchema.recover(Offsets<?,?> offsets)

Uses of Offsets in io.debezium.relational.history

Methods in io.debezium.relational.history with parameters of type Offsets

Modifier and Type	Method	Description
default void	SchemaHistory.recover(Offsets<?,?> offsets, Tables schema, DdlParser ddlParser)	Recover the database schema to a known point in its history.

Uses of Offsets in io.debezium.schema

Methods in io.debezium.schema with parameters of type Offsets

Modifier and Type	Method	Description
void	HistorizedDatabaseSchema.recover(Offsets<?,?> offsets)