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

Interface DebeziumReader<T,Split>

All Known Implementing Classes:

BinlogSplitReader, SnapshotSplitReader

public interface DebeziumReader<T,Split>

Reader to read split of table, the split is either snapshot split or binlog split.

Method Summary

Modifier and Type	Method and Description
void	close() Close the reader and releases all resources.
boolean	isFinished() Return the current split of the reader is finished or not.
Iterator<T>	pollSplitRecords() Reads records from MySQL.
void	submitSplit(Split splitToRead) Add to split to read, this should call only the when reader is idle.

Method Detail

isFinished

boolean isFinished()

Return the current split of the reader is finished or not.

submitSplit

void submitSplit(Split splitToRead)

Add to split to read, this should call only the when reader is idle.

Parameters:

splitToRead -

close

void close()

Close the reader and releases all resources.

pollSplitRecords

@Nullable
Iterator<T> pollSplitRecords()
                                throws InterruptedException

Reads records from MySQL. The method should return null when reaching the end of the split, the empty Iterator will be returned if the data of split is on pulling.

Throws:

InterruptedException