Package org.apache.flink.cdc.connectors.db2.source.fetch

Class Db2StreamFetchTask.StreamSplitReadTask

java.lang.Object

io.debezium.connector.db2.Db2StreamingChangeEventSource

org.apache.flink.cdc.connectors.db2.source.fetch.Db2StreamFetchTask.StreamSplitReadTask

All Implemented Interfaces:

io.debezium.pipeline.source.spi.ChangeEventSource, io.debezium.pipeline.source.spi.StreamingChangeEventSource<io.debezium.connector.db2.Db2Partition,io.debezium.connector.db2.Db2OffsetContext>

Enclosing class:

Db2StreamFetchTask

public static class Db2StreamFetchTask.StreamSplitReadTask
extends Db2StreamingChangeEventSource

A wrapped task to read all redo logs for table and also supports read bounded (from lowWatermark to highWatermark) redo logs.

Nested Class Summary

Nested classes/interfaces inherited from interface io.debezium.pipeline.source.spi.ChangeEventSource

io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext

Constructor Summary

Constructors

Constructor

Description

StreamSplitReadTask(io.debezium.connector.db2.Db2ConnectorConfig connectorConfig, Db2Connection connection, Db2Connection metadataConnection, io.debezium.pipeline.EventDispatcher<io.debezium.connector.db2.Db2Partition,io.debezium.relational.TableId> eventDispatcher, WatermarkDispatcher watermarkDispatcher, io.debezium.pipeline.ErrorHandler errorHandler, io.debezium.connector.db2.Db2DatabaseSchema schema, StreamSplit lsnSplit)

Method Summary

Modifier and Type	Method	Description
void	afterHandleLsn(io.debezium.connector.db2.Db2Partition partition, io.debezium.connector.db2.Lsn toLsn)	expose control to the user to stop the connector.
void	execute(io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext context, io.debezium.connector.db2.Db2Partition partition, io.debezium.connector.db2.Db2OffsetContext offsetContext)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.debezium.pipeline.source.spi.StreamingChangeEventSource

commitOffset, executeIteration, init

Constructor Detail

StreamSplitReadTask

public StreamSplitReadTask(io.debezium.connector.db2.Db2ConnectorConfig connectorConfig,
                           Db2Connection connection,
                           Db2Connection metadataConnection,
                           io.debezium.pipeline.EventDispatcher<io.debezium.connector.db2.Db2Partition,io.debezium.relational.TableId> eventDispatcher,
                           WatermarkDispatcher watermarkDispatcher,
                           io.debezium.pipeline.ErrorHandler errorHandler,
                           io.debezium.connector.db2.Db2DatabaseSchema schema,
                           StreamSplit lsnSplit)

Method Detail

afterHandleLsn

public void afterHandleLsn(io.debezium.connector.db2.Db2Partition partition,
                           io.debezium.connector.db2.Lsn toLsn)

Description copied from class: Db2StreamingChangeEventSource

expose control to the user to stop the connector.

Overrides:

afterHandleLsn in class Db2StreamingChangeEventSource

execute

public void execute(io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext context,
                    io.debezium.connector.db2.Db2Partition partition,
                    io.debezium.connector.db2.Db2OffsetContext offsetContext)
             throws InterruptedException

Specified by:

execute in interface io.debezium.pipeline.source.spi.StreamingChangeEventSource<io.debezium.connector.db2.Db2Partition,io.debezium.connector.db2.Db2OffsetContext>

Overrides:

execute in class Db2StreamingChangeEventSource

Throws:

InterruptedException