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

Class MySqlSourceReaderContext

java.lang.Object

org.apache.flink.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	Description
MySqlSourceReaderContext(org.apache.flink.api.connector.source.SourceReaderContext sourceReaderContext)

Method Summary

Modifier and Type	Method	Description
org.apache.flink.api.connector.source.SourceReaderContext	getSourceReaderContext()
boolean	isBinlogSplitReaderSuspended()
boolean	isHasAssignedBinlogSplit()
void	setHasAssignedBinlogSplit(boolean hasAssignedBinlogSplit)
void	suspendBinlogSplitReader()
void	wakeupSuspendedBinlogSplitReader()

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()

isBinlogSplitReaderSuspended

public boolean isBinlogSplitReaderSuspended()

suspendBinlogSplitReader

public void suspendBinlogSplitReader()

wakeupSuspendedBinlogSplitReader

public void wakeupSuspendedBinlogSplitReader()

isHasAssignedBinlogSplit

public boolean isHasAssignedBinlogSplit()

setHasAssignedBinlogSplit

public void setHasAssignedBinlogSplit(boolean hasAssignedBinlogSplit)