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

Class IncrementalSourceReaderContext

java.lang.Object

org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceReaderContext

public class IncrementalSourceReaderContext
extends Object

A wrapper class that wraps SourceReaderContext for sharing message between IncrementalSourceReader and IncrementalSourceSplitReader.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
org.apache.flink.api.connector.source.SourceReaderContext	getSourceReaderContext()
boolean	isHasAssignedStreamSplit()
boolean	isStreamSplitReaderSuspended()
void	setHasAssignedStreamSplit(boolean hasAssignedStreamSplit)
void	suspendStreamSplitReader()
void	wakeupSuspendedStreamSplitReader()

Methods inherited from class java.lang.Object

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

Constructor Detail

IncrementalSourceReaderContext

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

Method Detail

getSourceReaderContext

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

isStreamSplitReaderSuspended

public boolean isStreamSplitReaderSuspended()

suspendStreamSplitReader

public void suspendStreamSplitReader()

wakeupSuspendedStreamSplitReader

public void wakeupSuspendedStreamSplitReader()

isHasAssignedStreamSplit

public boolean isHasAssignedStreamSplit()

setHasAssignedStreamSplit

public void setHasAssignedStreamSplit(boolean hasAssignedStreamSplit)