org.apache.flink.runtime.operators.util

Class DistributedRuntimeUDFContext

java.lang.Object

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

org.apache.flink.runtime.operators.util.DistributedRuntimeUDFContext

All Implemented Interfaces:

org.apache.flink.api.common.functions.RuntimeContext

public class DistributedRuntimeUDFContext
extends org.apache.flink.api.common.functions.util.AbstractRuntimeUDFContext

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

Constructor Summary

Constructors

Constructor and Description
DistributedRuntimeUDFContext(String name, int numParallelSubtasks, int subtaskIndex, ClassLoader userCodeClassLoader, org.apache.flink.api.common.ExecutionConfig executionConfig)
DistributedRuntimeUDFContext(String name, int numParallelSubtasks, int subtaskIndex, ClassLoader userCodeClassLoader, org.apache.flink.api.common.ExecutionConfig executionConfig, Map<String,Future<org.apache.flink.core.fs.Path>> cpTasks)

Method Summary

Modifier and Type	Method and Description
void	clearAllBroadcastVariables()
void	clearBroadcastVariable(String name)
<T> List<T>	getBroadcastVariable(String name)
<T,C> C	getBroadcastVariableWithInitializer(String name, org.apache.flink.api.common.functions.BroadcastVariableInitializer<T,C> initializer)
void	setBroadcastVariable(String name, BroadcastVariableMaterialization<?,?> value)

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

addAccumulator, getAccumulator, getAllAccumulators, getDistributedCache, getDoubleCounter, getExecutionConfig, getHistogram, getIndexOfThisSubtask, getIntCounter, getLongCounter, getNumberOfParallelSubtasks, getTaskName, getUserCodeClassLoader

Methods inherited from class java.lang.Object

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

Constructor Detail

DistributedRuntimeUDFContext

public DistributedRuntimeUDFContext(String name,
                                    int numParallelSubtasks,
                                    int subtaskIndex,
                                    ClassLoader userCodeClassLoader,
                                    org.apache.flink.api.common.ExecutionConfig executionConfig)

DistributedRuntimeUDFContext

public DistributedRuntimeUDFContext(String name,
                                    int numParallelSubtasks,
                                    int subtaskIndex,
                                    ClassLoader userCodeClassLoader,
                                    org.apache.flink.api.common.ExecutionConfig executionConfig,
                                    Map<String,Future<org.apache.flink.core.fs.Path>> cpTasks)

Method Detail

getBroadcastVariable

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

getBroadcastVariableWithInitializer

public <T,C> C getBroadcastVariableWithInitializer(String name,
                                                   org.apache.flink.api.common.functions.BroadcastVariableInitializer<T,C> initializer)

setBroadcastVariable

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

clearBroadcastVariable

public void clearBroadcastVariable(String name)

clearAllBroadcastVariables

public void clearAllBroadcastVariables()