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.java.operators.translation
org.apache.flink.cep.nfa
org.apache.flink.cep.pattern.conditions
org.apache.flink.optimizer.util
org.apache.flink.runtime.operators.chaining
org.apache.flink.runtime.operators.util
org.apache.flink.streaming.api.functions.async
org.apache.flink.streaming.api.functions.sink
org.apache.flink.streaming.api.functions.windowing
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.connectors.elasticsearch
org.apache.flink.streaming.connectors.elasticsearch2
org.apache.flink.streaming.connectors.nifi
org.apache.flink.streaming.python.util
org.apache.flink.streaming.runtime.operators.windowing.functions
org.apache.flink.table.functions

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

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

Modifier and Type	Interface and 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 and 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 of the task that executes the function.

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

Modifier and Type	Method and 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 and 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 and Description
static RuntimeContext	FunctionUtils.getFunctionRuntimeContext(Function function, RuntimeContext defaultContext)

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

Modifier and Type	Method and Description
static RuntimeContext	FunctionUtils.getFunctionRuntimeContext(Function function, RuntimeContext defaultContext)
static void	FunctionUtils.setFunctionRuntimeContext(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 and 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 and 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 and 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 and Description
protected void	GenericDataSinkBase.executeOnCollections(List<IN> inputData, RuntimeContext ctx, ExecutionConfig executionConfig)
protected abstract List<OUT>	SingleInputOperator.executeOnCollections(List<IN> inputData, RuntimeContext runtimeContext, ExecutionConfig executionConfig)
protected abstract List<OUT>	DualInputOperator.executeOnCollections(List<IN1> inputData1, List<IN2> inputData2, RuntimeContext runtimeContext, ExecutionConfig executionConfig)
protected List<T>	Union.executeOnCollections(List<T> inputData1, List<T> inputData2, RuntimeContext runtimeContext, ExecutionConfig executionConfig)
protected List<OUT>	GenericDataSourceBase.executeOnCollections(RuntimeContext ctx, 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 and Description
protected List<OUT>	MapPartitionOperatorBase.executeOnCollections(List<IN> inputData, RuntimeContext ctx, ExecutionConfig executionConfig)
protected List<OUT>	GroupReduceOperatorBase.executeOnCollections(List<IN> inputData, RuntimeContext ctx, ExecutionConfig executionConfig)
protected List<OUT>	GroupCombineOperatorBase.executeOnCollections(List<IN> inputData, RuntimeContext ctx, ExecutionConfig executionConfig)
protected List<IN>	SortPartitionOperatorBase.executeOnCollections(List<IN> inputData, RuntimeContext runtimeContext, ExecutionConfig executionConfig)
protected List<OUT>	MapOperatorBase.executeOnCollections(List<IN> inputData, RuntimeContext ctx, ExecutionConfig executionConfig)
protected List<OUT>	FlatMapOperatorBase.executeOnCollections(List<IN> input, RuntimeContext ctx, ExecutionConfig executionConfig)
protected List<IN>	PartitionOperatorBase.executeOnCollections(List<IN> inputData, RuntimeContext runtimeContext, ExecutionConfig executionConfig)
protected List<OUT>	OuterJoinOperatorBase.executeOnCollections(List<IN1> leftInput, List<IN2> rightInput, RuntimeContext runtimeContext, ExecutionConfig executionConfig)
protected List<OUT>	CrossOperatorBase.executeOnCollections(List<IN1> inputData1, List<IN2> inputData2, RuntimeContext ctx, ExecutionConfig executionConfig)
protected List<OUT>	CoGroupRawOperatorBase.executeOnCollections(List<IN1> input1, List<IN2> input2, RuntimeContext ctx, ExecutionConfig executionConfig)
protected List<OUT>	CoGroupOperatorBase.executeOnCollections(List<IN1> input1, List<IN2> input2, RuntimeContext ctx, ExecutionConfig executionConfig)
protected List<OUT>	InnerJoinOperatorBase.executeOnCollections(List<IN1> inputData1, List<IN2> inputData2, RuntimeContext runtimeContext, ExecutionConfig executionConfig)
protected List<ST>	DeltaIterationBase.executeOnCollections(List<ST> inputData1, List<WT> inputData2, RuntimeContext runtimeContext, ExecutionConfig executionConfig)
protected List<T>	ReduceOperatorBase.executeOnCollections(List<T> inputData, RuntimeContext ctx, ExecutionConfig executionConfig)
protected List<T>	BulkIterationBase.executeOnCollections(List<T> inputData, RuntimeContext runtimeContext, ExecutionConfig executionConfig)
protected List<T>	FilterOperatorBase.executeOnCollections(List<T> inputData, RuntimeContext ctx, ExecutionConfig executionConfig)

Uses of RuntimeContext in org.apache.flink.api.java.operators.translation

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

Modifier and Type	Method and Description
void	WrappingFunction.setRuntimeContext(RuntimeContext t)

Uses of RuntimeContext in org.apache.flink.cep.nfa

Methods in org.apache.flink.cep.nfa with parameters of type RuntimeContext

Modifier and Type	Method and Description
void	NFA.open(RuntimeContext cepRuntimeContext, Configuration conf) Initialization method for the NFA.

Uses of RuntimeContext in org.apache.flink.cep.pattern.conditions

Methods in org.apache.flink.cep.pattern.conditions that return RuntimeContext

Modifier and Type	Method and Description
RuntimeContext	RichIterativeCondition.getRuntimeContext()

Methods in org.apache.flink.cep.pattern.conditions with parameters of type RuntimeContext

Modifier and Type	Method and Description
void	RichCompositeIterativeCondition.setRuntimeContext(RuntimeContext t)
void	RichIterativeCondition.setRuntimeContext(RuntimeContext runtimeContext)

Uses of RuntimeContext in org.apache.flink.optimizer.util

Methods in org.apache.flink.optimizer.util with parameters of type RuntimeContext

Modifier and Type	Method and Description
protected List<OUT>	NoOpBinaryUdfOp.executeOnCollections(List<OUT> inputData1, List<OUT> inputData2, RuntimeContext runtimeContext, ExecutionConfig executionConfig)
protected List<OUT>	NoOpUnaryUdfOp.executeOnCollections(List<OUT> inputData, RuntimeContext runtimeContext, ExecutionConfig executionConfig)

Uses of RuntimeContext in org.apache.flink.runtime.operators.chaining

Methods in org.apache.flink.runtime.operators.chaining that return RuntimeContext

Modifier and Type	Method and Description
protected RuntimeContext	ChainedDriver.getUdfRuntimeContext()

Uses of RuntimeContext in org.apache.flink.runtime.operators.util

Classes in org.apache.flink.runtime.operators.util that implement RuntimeContext

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

Uses of RuntimeContext in org.apache.flink.streaming.api.functions.async

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

Modifier and Type	Method and Description
void	RichAsyncFunction.setRuntimeContext(RuntimeContext runtimeContext)

Uses of RuntimeContext in org.apache.flink.streaming.api.functions.sink

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

Modifier and Type	Method and Description
void	OutputFormatSinkFunction.setRuntimeContext(RuntimeContext context) Deprecated.

Uses of RuntimeContext in org.apache.flink.streaming.api.functions.windowing

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

Modifier and Type	Method and Description
void	FoldApplyProcessWindowFunction.setRuntimeContext(RuntimeContext t) Deprecated.
void	FoldApplyProcessAllWindowFunction.setRuntimeContext(RuntimeContext t) Deprecated.
void	ReduceApplyProcessWindowFunction.setRuntimeContext(RuntimeContext t)
void	ReduceApplyProcessAllWindowFunction.setRuntimeContext(RuntimeContext t)

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

Classes in org.apache.flink.streaming.api.operators that implement RuntimeContext

Modifier and Type	Class and Description
class	StreamingRuntimeContext Implementation of the RuntimeContext, for streaming operators.

Uses of RuntimeContext in org.apache.flink.streaming.connectors.elasticsearch

Methods in org.apache.flink.streaming.connectors.elasticsearch with parameters of type RuntimeContext

Modifier and Type	Method and Description
org.elasticsearch.action.index.IndexRequest	IndexRequestBuilder.createIndexRequest(T element, RuntimeContext ctx) Deprecated. Creates an IndexRequest from an element.
void	ElasticsearchSinkFunction.process(T element, RuntimeContext ctx, RequestIndexer indexer) Process the incoming element to produce multiple ActionsRequests.
void	ElasticsearchUpsertTableSinkBase.ElasticsearchUpsertSinkFunction.process(Tuple2<Boolean,Row> element, RuntimeContext ctx, RequestIndexer indexer)

Uses of RuntimeContext in org.apache.flink.streaming.connectors.elasticsearch2

Methods in org.apache.flink.streaming.connectors.elasticsearch2 with parameters of type RuntimeContext

Modifier and Type	Method and Description
void	ElasticsearchSinkFunction.process(T element, RuntimeContext ctx, RequestIndexer indexer) Deprecated.

Uses of RuntimeContext in org.apache.flink.streaming.connectors.nifi

Methods in org.apache.flink.streaming.connectors.nifi with parameters of type RuntimeContext

Modifier and Type	Method and Description
NiFiDataPacket	NiFiDataPacketBuilder.createNiFiDataPacket(T t, RuntimeContext ctx)

Uses of RuntimeContext in org.apache.flink.streaming.python.util

Methods in org.apache.flink.streaming.python.util with parameters of type RuntimeContext

Modifier and Type	Method and Description
static <X> X	InterpreterUtils.deserializeFunction(RuntimeContext context, byte[] serFun) Deserialize the given python function.

Uses of RuntimeContext in org.apache.flink.streaming.runtime.operators.windowing.functions

Methods in org.apache.flink.streaming.runtime.operators.windowing.functions that return RuntimeContext

Modifier and Type	Method and Description
RuntimeContext	InternalIterableProcessAllWindowFunction.getRuntimeContext()
RuntimeContext	InternalAggregateProcessWindowFunction.getRuntimeContext()
RuntimeContext	InternalIterableProcessWindowFunction.getRuntimeContext()
RuntimeContext	InternalAggregateProcessAllWindowFunction.getRuntimeContext()
RuntimeContext	InternalSingleValueProcessAllWindowFunction.getRuntimeContext()
RuntimeContext	InternalSingleValueWindowFunction.getRuntimeContext()
RuntimeContext	InternalSingleValueAllWindowFunction.getRuntimeContext()
RuntimeContext	InternalSingleValueProcessWindowFunction.getRuntimeContext()
RuntimeContext	InternalIterableWindowFunction.getRuntimeContext()
RuntimeContext	InternalIterableAllWindowFunction.getRuntimeContext()

Uses of RuntimeContext in org.apache.flink.table.functions

Constructors in org.apache.flink.table.functions with parameters of type RuntimeContext

Constructor and Description
FunctionContext(RuntimeContext context) Wraps the underlying RuntimeContext.