Package org.apache.flink.api.connector.source

Class RichSourceReaderContext

java.lang.Object

org.apache.flink.api.connector.source.RichSourceReaderContext

All Implemented Interfaces:

SourceReaderContext

@Experimental
public abstract class RichSourceReaderContext
extends Object
implements SourceReaderContext

An abstract stub implementation for SourceReaderContext. Rich formats have access to their runtime execution context via getRuntimeContext().

Constructor Summary

Constructors

Constructor	Description
RichSourceReaderContext()

Method Summary

Modifier and Type	Method	Description
RuntimeContext	getRuntimeContext()
void	setRuntimeContext(RuntimeContext runtimeContext)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.api.connector.source.SourceReaderContext

currentParallelism, emitWatermark, getConfiguration, getIndexOfSubtask, getLocalHostName, getUserCodeClassLoader, metricGroup, sendSourceEventToCoordinator, sendSplitRequest

Constructor Detail

RichSourceReaderContext

public RichSourceReaderContext()

Method Detail

setRuntimeContext

public void setRuntimeContext(RuntimeContext runtimeContext)

getRuntimeContext

public RuntimeContext getRuntimeContext()