Class Db2ScanFetchTask.Db2SnapshotSplitChangeEventSourceContext
- java.lang.Object
-
- org.apache.flink.cdc.connectors.db2.source.fetch.Db2ScanFetchTask.Db2SnapshotSplitChangeEventSourceContext
-
- All Implemented Interfaces:
io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext
- Enclosing class:
- Db2ScanFetchTask
public class Db2ScanFetchTask.Db2SnapshotSplitChangeEventSourceContext extends Object implements io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext
TheChangeEventSource.ChangeEventSourceContextimplementation for bounded stream task of a snapshot split task.
-
-
Constructor Summary
Constructors Constructor Description Db2SnapshotSplitChangeEventSourceContext()
-