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

Class BinlogSplitReader

java.lang.Object

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

All Implemented Interfaces:

DebeziumReader<SourceRecords,MySqlSplit>

public class BinlogSplitReader
extends Object
implements DebeziumReader<SourceRecords,MySqlSplit>

A Debezium binlog reader implementation that also support reads binlog and filter overlapping snapshot data that SnapshotSplitReader read.

Constructor Summary

Constructors

Constructor	Description
BinlogSplitReader(StatefulTaskContext statefulTaskContext, int subtaskId)
BinlogSplitReader(MySqlSourceConfig sourceConfig, int subtaskId)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

BinlogSplitReader

public BinlogSplitReader(MySqlSourceConfig sourceConfig,
                         int subtaskId)

BinlogSplitReader

public BinlogSplitReader(StatefulTaskContext statefulTaskContext,
                         int subtaskId)

Method Detail

submitSplit

public void submitSplit(MySqlSplit mySqlSplit)

Description copied from interface: DebeziumReader

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

Specified by:

submitSplit in interface DebeziumReader<SourceRecords,MySqlSplit>

isFinished

public boolean isFinished()

Description copied from interface: DebeziumReader

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

Specified by:

isFinished in interface DebeziumReader<SourceRecords,MySqlSplit>

pollSplitRecords

@Nullable
public Iterator<SourceRecords> pollSplitRecords()
                                         throws InterruptedException

Description copied from interface: DebeziumReader

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.

Specified by:

pollSplitRecords in interface DebeziumReader<SourceRecords,MySqlSplit>

Throws:

InterruptedException

close

public void close()

Description copied from interface: DebeziumReader

Close the reader and releases all resources.

Specified by:

close in interface DebeziumReader<SourceRecords,MySqlSplit>

stopBinlogReadTask

public void stopBinlogReadTask()

getExecutorService

@VisibleForTesting
public ExecutorService getExecutorService()

getChangeEventSourceContext

@VisibleForTesting
public StoppableChangeEventSourceContext getChangeEventSourceContext()