com.ververica.cdc.connectors.mysql.source.reader

Class MySqlSourceReaderContext

java.lang.Object

com.ververica.cdc.connectors.mysql.source.reader.MySqlSourceReaderContext

public class MySqlSourceReaderContext
extends Object

A wrapper class that wraps SourceReaderContext for sharing message between MySqlSourceReader and MySqlSplitReader.

Constructor Summary

Constructors

Constructor and Description
MySqlSourceReaderContext(org.apache.flink.api.connector.source.SourceReaderContext sourceReaderContext)

Method Summary

Modifier and Type	Method and Description
org.apache.flink.api.connector.source.SourceReaderContext	getSourceReaderContext()
boolean	needStopBinlogSplitReader()
void	resetStopBinlogSplitReader()
void	setStopBinlogSplitReader()

Methods inherited from class java.lang.Object

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

Constructor Detail

MySqlSourceReaderContext

public MySqlSourceReaderContext(org.apache.flink.api.connector.source.SourceReaderContext sourceReaderContext)

Method Detail

getSourceReaderContext

public org.apache.flink.api.connector.source.SourceReaderContext getSourceReaderContext()

needStopBinlogSplitReader

public boolean needStopBinlogSplitReader()

setStopBinlogSplitReader

public void setStopBinlogSplitReader()

resetStopBinlogSplitReader

public void resetStopBinlogSplitReader()