Package org.apache.flink.cdc.connectors.mysql.debezium.reader

Interface Summary

Interface	Description
DebeziumReader<T,Split>	Reader to read split of table, the split is either snapshot split or binlog split.

Class Summary

Class	Description
BinlogSplitReader	A Debezium binlog reader implementation that also support reads binlog and filter overlapping snapshot data that SnapshotSplitReader read.
SnapshotSplitReader	A snapshot reader that reads data from Table in split level, the split is assigned by primary key range.
SnapshotSplitReader.SnapshotSplitChangeEventSourceContextImpl	ChangeEventSource.ChangeEventSourceContext implementation that keeps low/high watermark for each MySqlSnapshotSplit.
StoppableChangeEventSourceContext	A change event source context that can stop the running source by invoking StoppableChangeEventSourceContext.stopChangeEventSource().