Uses of Interface
org.apache.flink.api.common.functions.RuntimeContext

Packages that use RuntimeContext

Package	Description
org.apache.flink.api.common.functions
org.apache.flink.api.common.functions.util
org.apache.flink.api.common.io
org.apache.flink.api.common.io.ratelimiting
org.apache.flink.api.common.operators
org.apache.flink.api.common.operators.base
org.apache.flink.api.common.serialization

Uses of RuntimeContext in org.apache.flink.api.common.functions

Subinterfaces of RuntimeContext in org.apache.flink.api.common.functions

Modifier and Type	Interface	Description
interface	IterationRuntimeContext	A specialization of the RuntimeContext available in iterative computations of the DataSet API.

Methods in org.apache.flink.api.common.functions that return RuntimeContext

Modifier and Type	Method	Description
RuntimeContext	AbstractRichFunction.getRuntimeContext()
RuntimeContext	RichFunction.getRuntimeContext()	Gets the context that contains information about the UDF's runtime, such as the parallelism of the function, the subtask index of the function, or the name of the task that executes the function.

Methods in org.apache.flink.api.common.functions with parameters of type RuntimeContext

Modifier and Type	Method	Description
void	AbstractRichFunction.setRuntimeContext(RuntimeContext t)
void	RichFunction.setRuntimeContext(RuntimeContext t)	Sets the function's runtime context.

Uses of RuntimeContext in org.apache.flink.api.common.functions.util

Classes in org.apache.flink.api.common.functions.util that implement RuntimeContext

Modifier and Type	Class	Description
class	AbstractRuntimeUDFContext	A standalone implementation of the RuntimeContext, created by runtime UDF operators.
class	RuntimeUDFContext	A standalone implementation of the RuntimeContext, created by runtime UDF operators.

Methods in org.apache.flink.api.common.functions.util that return RuntimeContext

Modifier and Type	Method	Description
static RuntimeContext	FunctionUtils.getFunctionRuntimeContext(org.apache.flink.api.common.functions.Function function, RuntimeContext defaultContext)

Methods in org.apache.flink.api.common.functions.util with parameters of type RuntimeContext

Modifier and Type	Method	Description
static RuntimeContext	FunctionUtils.getFunctionRuntimeContext(org.apache.flink.api.common.functions.Function function, RuntimeContext defaultContext)
static void	FunctionUtils.setFunctionRuntimeContext(org.apache.flink.api.common.functions.Function function, RuntimeContext context)

Uses of RuntimeContext in org.apache.flink.api.common.io

Methods in org.apache.flink.api.common.io that return RuntimeContext

Modifier and Type	Method	Description
RuntimeContext	ReplicatingInputFormat.getRuntimeContext()
RuntimeContext	RichInputFormat.getRuntimeContext()
RuntimeContext	RichOutputFormat.getRuntimeContext()

Methods in org.apache.flink.api.common.io with parameters of type RuntimeContext

Modifier and Type	Method	Description
void	ReplicatingInputFormat.setRuntimeContext(RuntimeContext context)
void	RichInputFormat.setRuntimeContext(RuntimeContext t)
void	RichOutputFormat.setRuntimeContext(RuntimeContext t)

Uses of RuntimeContext in org.apache.flink.api.common.io.ratelimiting

Methods in org.apache.flink.api.common.io.ratelimiting with parameters of type RuntimeContext

Modifier and Type	Method	Description
void	FlinkConnectorRateLimiter.open(RuntimeContext runtimeContext)	A method that can be used to create and configure a ratelimiter based on the runtimeContext.
void	GuavaFlinkConnectorRateLimiter.open(RuntimeContext runtimeContext)	Creates a rate limiter with the runtime context provided.

Uses of RuntimeContext in org.apache.flink.api.common.operators

Methods in org.apache.flink.api.common.operators with parameters of type RuntimeContext

Modifier and Type	Method	Description
protected abstract List<OUT>	DualInputOperator.executeOnCollections(List<IN1> inputData1, List<IN2> inputData2, RuntimeContext runtimeContext, ExecutionConfig executionConfig)
protected void	GenericDataSinkBase.executeOnCollections(List<IN> inputData, RuntimeContext ctx, ExecutionConfig executionConfig)
protected List<OUT>	GenericDataSourceBase.executeOnCollections(RuntimeContext ctx, ExecutionConfig executionConfig)
protected abstract List<OUT>	SingleInputOperator.executeOnCollections(List<IN> inputData, RuntimeContext runtimeContext, ExecutionConfig executionConfig)
protected List<T>	Union.executeOnCollections(List<T> inputData1, List<T> inputData2, RuntimeContext runtimeContext, ExecutionConfig executionConfig)

Uses of RuntimeContext in org.apache.flink.api.common.operators.base

Methods in org.apache.flink.api.common.operators.base with parameters of type RuntimeContext

Modifier and Type	Method	Description
protected List<T>	BulkIterationBase.executeOnCollections(List<T> inputData, RuntimeContext runtimeContext, ExecutionConfig executionConfig)
protected List<OUT>	CoGroupOperatorBase.executeOnCollections(List<IN1> input1, List<IN2> input2, RuntimeContext ctx, ExecutionConfig executionConfig)
protected List<OUT>	CoGroupRawOperatorBase.executeOnCollections(List<IN1> input1, List<IN2> input2, RuntimeContext ctx, ExecutionConfig executionConfig)
protected List<OUT>	CrossOperatorBase.executeOnCollections(List<IN1> inputData1, List<IN2> inputData2, RuntimeContext ctx, ExecutionConfig executionConfig)
protected List<ST>	DeltaIterationBase.executeOnCollections(List<ST> inputData1, List<WT> inputData2, RuntimeContext runtimeContext, ExecutionConfig executionConfig)
protected List<T>	FilterOperatorBase.executeOnCollections(List<T> inputData, RuntimeContext ctx, ExecutionConfig executionConfig)
protected List<OUT>	FlatMapOperatorBase.executeOnCollections(List<IN> input, RuntimeContext ctx, ExecutionConfig executionConfig)
protected List<OUT>	GroupCombineOperatorBase.executeOnCollections(List<IN> inputData, RuntimeContext ctx, ExecutionConfig executionConfig)
protected List<OUT>	GroupReduceOperatorBase.executeOnCollections(List<IN> inputData, RuntimeContext ctx, ExecutionConfig executionConfig)
protected List<OUT>	InnerJoinOperatorBase.executeOnCollections(List<IN1> inputData1, List<IN2> inputData2, RuntimeContext runtimeContext, ExecutionConfig executionConfig)
protected List<OUT>	MapOperatorBase.executeOnCollections(List<IN> inputData, RuntimeContext ctx, ExecutionConfig executionConfig)
protected List<OUT>	MapPartitionOperatorBase.executeOnCollections(List<IN> inputData, RuntimeContext ctx, ExecutionConfig executionConfig)
protected List<OUT>	OuterJoinOperatorBase.executeOnCollections(List<IN1> leftInput, List<IN2> rightInput, RuntimeContext runtimeContext, ExecutionConfig executionConfig)
protected List<IN>	PartitionOperatorBase.executeOnCollections(List<IN> inputData, RuntimeContext runtimeContext, ExecutionConfig executionConfig)
protected List<T>	ReduceOperatorBase.executeOnCollections(List<T> inputData, RuntimeContext ctx, ExecutionConfig executionConfig)
protected List<IN>	SortPartitionOperatorBase.executeOnCollections(List<IN> inputData, RuntimeContext runtimeContext, ExecutionConfig executionConfig)

Uses of RuntimeContext in org.apache.flink.api.common.serialization

Methods in org.apache.flink.api.common.serialization with parameters of type RuntimeContext

Modifier and Type	Method	Description
static DeserializationSchema.InitializationContext	RuntimeContextInitializationContextAdapters.deserializationAdapter(RuntimeContext runtimeContext)
static DeserializationSchema.InitializationContext	RuntimeContextInitializationContextAdapters.deserializationAdapter(RuntimeContext runtimeContext, java.util.function.Function<org.apache.flink.metrics.MetricGroup,org.apache.flink.metrics.MetricGroup> mapMetricGroup)
static SerializationSchema.InitializationContext	RuntimeContextInitializationContextAdapters.serializationAdapter(RuntimeContext runtimeContext)
static SerializationSchema.InitializationContext	RuntimeContextInitializationContextAdapters.serializationAdapter(RuntimeContext runtimeContext, java.util.function.Function<org.apache.flink.metrics.MetricGroup,org.apache.flink.metrics.MetricGroup> mapMetricGroup)