com.ververica.cdc.connectors.mysql.debezium.reader

Class SnapshotSplitReader.SnapshotBinlogSplitChangeEventSourceContextImpl

java.lang.Object

com.ververica.cdc.connectors.mysql.debezium.reader.SnapshotSplitReader.SnapshotBinlogSplitChangeEventSourceContextImpl

All Implemented Interfaces:

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

Enclosing class:

SnapshotSplitReader

public class SnapshotSplitReader.SnapshotBinlogSplitChangeEventSourceContextImpl
extends Object
implements io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext

The ChangeEventSource.ChangeEventSourceContext implementation for bounded binlog task of a snapshot split task.

Constructor Summary

Constructors

Constructor and Description
SnapshotBinlogSplitChangeEventSourceContextImpl()

Method Summary

Modifier and Type	Method and Description
void	finished()
boolean	isRunning()

Methods inherited from class java.lang.Object

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

Constructor Detail

SnapshotBinlogSplitChangeEventSourceContextImpl

public SnapshotBinlogSplitChangeEventSourceContextImpl()

Method Detail

finished

public void finished()

isRunning

public boolean isRunning()

Specified by:

isRunning in interface io.debezium.pipeline.source.spi.ChangeEventSource.ChangeEventSourceContext