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

Class SnapshotSplitReader.SnapshotSplitChangeEventSourceContextImpl

java.lang.Object

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

All Implemented Interfaces:

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

Enclosing class:

SnapshotSplitReader

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

ChangeEventSource.ChangeEventSourceContext implementation that keeps low/high watermark for each MySqlSnapshotSplit.

Constructor Summary

Constructors

Constructor and Description
SnapshotSplitChangeEventSourceContextImpl()

Method Summary

Modifier and Type	Method and Description
BinlogOffset	getHighWatermark()
BinlogOffset	getLowWatermark()
boolean	isRunning()
void	setHighWatermark(BinlogOffset highWatermark)
void	setLowWatermark(BinlogOffset lowWatermark)

Methods inherited from class java.lang.Object

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

Constructor Detail

SnapshotSplitChangeEventSourceContextImpl

public SnapshotSplitChangeEventSourceContextImpl()

Method Detail

getLowWatermark

public BinlogOffset getLowWatermark()

setLowWatermark

public void setLowWatermark(BinlogOffset lowWatermark)

getHighWatermark

public BinlogOffset getHighWatermark()

setHighWatermark

public void setHighWatermark(BinlogOffset highWatermark)

isRunning

public boolean isRunning()

Specified by:

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