DebeziumReader (flink-cdc-parent 3.8-SNAPSHOT API)

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

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