SnapshotSplitReader.SnapshotSplitChangeEventSourceContextImpl (flink-cdc-parent 3.8-SNAPSHOT API)

java.lang.Object
- org.apache.flink.cdc.connectors.mysql.debezium.reader.SnapshotSplitReader.SnapshotSplitChangeEventSourceContextImpl

All Implemented Interfaces:

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

Enclosing class:

SnapshotSplitReader
```
public static 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 Description

SnapshotSplitChangeEventSourceContextImpl()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	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