Uses of Class
io.debezium.connector.sqlserver.SqlServerOffsetContext

Packages that use SqlServerOffsetContext

Package	Description
io.debezium.connector.sqlserver
org.apache.flink.cdc.connectors.sqlserver.source.reader.fetch

Uses of SqlServerOffsetContext in io.debezium.connector.sqlserver

Methods in io.debezium.connector.sqlserver that return SqlServerOffsetContext

Modifier and Type	Method	Description
SqlServerOffsetContext	SqlServerOffsetContext.Loader.load(Map<String,?> offset)

Methods in io.debezium.connector.sqlserver with parameters of type SqlServerOffsetContext

Modifier and Type	Method	Description
void	SqlServerStreamingChangeEventSource.execute(io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext context, io.debezium.connector.sqlserver.SqlServerPartition partition, SqlServerOffsetContext offsetContext)
boolean	SqlServerStreamingChangeEventSource.executeIteration(io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext context, io.debezium.connector.sqlserver.SqlServerPartition partition, SqlServerOffsetContext offsetContext)

Uses of SqlServerOffsetContext in org.apache.flink.cdc.connectors.sqlserver.source.reader.fetch

Methods in org.apache.flink.cdc.connectors.sqlserver.source.reader.fetch that return SqlServerOffsetContext

Modifier and Type	Method	Description
SqlServerOffsetContext	SqlServerSourceFetchTaskContext.getOffsetContext()

Methods in org.apache.flink.cdc.connectors.sqlserver.source.reader.fetch that return types with arguments of type SqlServerOffsetContext

Modifier and Type	Method	Description
protected io.debezium.pipeline.spi.SnapshotResult<SqlServerOffsetContext>	SqlServerScanFetchTask.SqlServerSnapshotSplitReadTask.doExecute(io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext context, SqlServerOffsetContext previousOffset, io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshotContext<io.debezium.connector.sqlserver.SqlServerPartition,SqlServerOffsetContext> snapshotContext, io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshottingTask snapshottingTask)
io.debezium.pipeline.spi.SnapshotResult<SqlServerOffsetContext>	SqlServerScanFetchTask.SqlServerSnapshotSplitReadTask.execute(io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext context, io.debezium.connector.sqlserver.SqlServerPartition partition, SqlServerOffsetContext previousOffset)

Methods in org.apache.flink.cdc.connectors.sqlserver.source.reader.fetch with parameters of type SqlServerOffsetContext

Modifier and Type	Method	Description
protected io.debezium.pipeline.spi.SnapshotResult<SqlServerOffsetContext>	SqlServerScanFetchTask.SqlServerSnapshotSplitReadTask.doExecute(io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext context, SqlServerOffsetContext previousOffset, io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshotContext<io.debezium.connector.sqlserver.SqlServerPartition,SqlServerOffsetContext> snapshotContext, io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshottingTask snapshottingTask)
io.debezium.pipeline.spi.SnapshotResult<SqlServerOffsetContext>	SqlServerScanFetchTask.SqlServerSnapshotSplitReadTask.execute(io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext context, io.debezium.connector.sqlserver.SqlServerPartition partition, SqlServerOffsetContext previousOffset)
void	SqlServerStreamFetchTask.StreamSplitReadTask.execute(io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext context, io.debezium.connector.sqlserver.SqlServerPartition partition, SqlServerOffsetContext offsetContext)
protected io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshottingTask	SqlServerScanFetchTask.SqlServerSnapshotSplitReadTask.getSnapshottingTask(io.debezium.connector.sqlserver.SqlServerPartition partition, SqlServerOffsetContext previousOffset)

Method parameters in org.apache.flink.cdc.connectors.sqlserver.source.reader.fetch with type arguments of type SqlServerOffsetContext

Modifier and Type	Method	Description
protected io.debezium.pipeline.spi.SnapshotResult<SqlServerOffsetContext>	SqlServerScanFetchTask.SqlServerSnapshotSplitReadTask.doExecute(io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext context, SqlServerOffsetContext previousOffset, io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshotContext<io.debezium.connector.sqlserver.SqlServerPartition,SqlServerOffsetContext> snapshotContext, io.debezium.pipeline.source.AbstractSnapshotChangeEventSource.SnapshottingTask snapshottingTask)

Constructors in org.apache.flink.cdc.connectors.sqlserver.source.reader.fetch with parameters of type SqlServerOffsetContext

Constructor

Description

SqlServerSnapshotSplitReadTask(io.debezium.connector.sqlserver.SqlServerConnectorConfig connectorConfig, SqlServerOffsetContext previousOffset, io.debezium.pipeline.source.spi.SnapshotProgressListener<io.debezium.connector.sqlserver.SqlServerPartition> snapshotProgressListener, io.debezium.connector.sqlserver.SqlServerDatabaseSchema databaseSchema, io.debezium.connector.sqlserver.SqlServerConnection jdbcConnection, io.debezium.pipeline.EventDispatcher<io.debezium.connector.sqlserver.SqlServerPartition,io.debezium.relational.TableId> eventDispatcher, io.debezium.pipeline.EventDispatcher.SnapshotReceiver<io.debezium.connector.sqlserver.SqlServerPartition> snapshotReceiver, SnapshotSplit snapshotSplit)