Class 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
    The ChangeEventSource.ChangeEventSourceContext implementation for bounded stream task of a snapshot split task.
    • Constructor Detail

      • Db2SnapshotSplitChangeEventSourceContext

        public Db2SnapshotSplitChangeEventSourceContext()
    • Method Detail

      • finished

        public void finished()
      • isRunning

        public boolean isRunning()
        Specified by:
        isRunning in interface io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext