org.apache.flink.api.common.functions.util

Class RuntimeUDFContext

java.lang.Object

org.apache.flink.api.common.functions.util.AbstractRuntimeUDFContext

org.apache.flink.api.common.functions.util.RuntimeUDFContext

All Implemented Interfaces:

RuntimeContext

@Internal
public class RuntimeUDFContext
extends AbstractRuntimeUDFContext

A standalone implementation of the RuntimeContext, created by runtime UDF operators.

Constructor Summary

Constructors

Constructor and Description
RuntimeUDFContext(TaskInfo taskInfo, ClassLoader userCodeClassLoader, ExecutionConfig executionConfig, Map<String,Future<Path>> cpTasks, Map<String,Accumulator<?,?>> accumulators, MetricGroup metrics)

Method Summary

Modifier and Type	Method and Description
void	clearAllBroadcastVariables()
void	clearBroadcastVariable(String name)
<RT> List<RT>	getBroadcastVariable(String name) Returns the result bound to the broadcast variable identified by the given name.
<T,C> C	getBroadcastVariableWithInitializer(String name, BroadcastVariableInitializer<T,C> initializer) Returns the result bound to the broadcast variable identified by the given name.
boolean	hasBroadcastVariable(String name) Tests for the existence of the broadcast variable identified by the given name.
void	setBroadcastVariable(String name, List<?> value)

Methods inherited from class org.apache.flink.api.common.functions.util.AbstractRuntimeUDFContext

addAccumulator, getAccumulator, getAggregatingState, getAllAccumulators, getAllocationIDAsString, getAttemptNumber, getDistributedCache, getDoubleCounter, getExecutionConfig, getFoldingState, getHistogram, getIndexOfThisSubtask, getIntCounter, getListState, getLongCounter, getMapState, getMaxNumberOfParallelSubtasks, getMetricGroup, getNumberOfParallelSubtasks, getReducingState, getState, getTaskName, getTaskNameWithSubtasks, getUserCodeClassLoader

Methods inherited from class java.lang.Object

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

Constructor Detail

RuntimeUDFContext

public RuntimeUDFContext(TaskInfo taskInfo,
                         ClassLoader userCodeClassLoader,
                         ExecutionConfig executionConfig,
                         Map<String,Future<Path>> cpTasks,
                         Map<String,Accumulator<?,?>> accumulators,
                         MetricGroup metrics)

Method Detail

hasBroadcastVariable

public boolean hasBroadcastVariable(String name)

Description copied from interface: RuntimeContext

Tests for the existence of the broadcast variable identified by the given name.

Parameters:

name - The name under which the broadcast variable is registered;

Returns:

Whether a broadcast variable exists for the given name.

getBroadcastVariable

public <RT> List<RT> getBroadcastVariable(String name)

Description copied from interface: RuntimeContext

Returns the result bound to the broadcast variable identified by the given name.

IMPORTANT: The broadcast variable data structure is shared between the parallel tasks on one machine. Any access that modifies its internal state needs to be manually synchronized by the caller.

Parameters:

name - The name under which the broadcast variable is registered;

Returns:

The broadcast variable, materialized as a list of elements.

getBroadcastVariableWithInitializer

public <T,C> C getBroadcastVariableWithInitializer(String name,
                                                   BroadcastVariableInitializer<T,C> initializer)

Description copied from interface: RuntimeContext

Returns the result bound to the broadcast variable identified by the given name. The broadcast variable is returned as a shared data structure that is initialized with the given BroadcastVariableInitializer.

IMPORTANT: The broadcast variable data structure is shared between the parallel tasks on one machine. Any access that modifies its internal state needs to be manually synchronized by the caller.

Parameters:

name - The name under which the broadcast variable is registered;

initializer - The initializer that creates the shared data structure of the broadcast variable from the sequence of elements.

Returns:

The broadcast variable, materialized as a list of elements.

setBroadcastVariable

public void setBroadcastVariable(String name,
                                 List<?> value)

clearBroadcastVariable

public void clearBroadcastVariable(String name)

clearAllBroadcastVariables

public void clearAllBroadcastVariables()