Uses of Class
org.apache.flink.runtime.operators.util.DistributedRuntimeUDFContext
-
Packages that use DistributedRuntimeUDFContext Package Description org.apache.flink.runtime.iterative.task org.apache.flink.runtime.operators -
-
Uses of DistributedRuntimeUDFContext in org.apache.flink.runtime.iterative.task
Methods in org.apache.flink.runtime.iterative.task that return DistributedRuntimeUDFContext Modifier and Type Method Description DistributedRuntimeUDFContext
AbstractIterativeTask. createRuntimeContext(OperatorMetricGroup metrics)
-
Uses of DistributedRuntimeUDFContext in org.apache.flink.runtime.operators
Fields in org.apache.flink.runtime.operators declared as DistributedRuntimeUDFContext Modifier and Type Field Description protected DistributedRuntimeUDFContext
BatchTask. runtimeUdfContext
The udf's runtime context.Methods in org.apache.flink.runtime.operators that return DistributedRuntimeUDFContext Modifier and Type Method Description DistributedRuntimeUDFContext
BatchTask. createRuntimeContext(OperatorMetricGroup metrics)
DistributedRuntimeUDFContext
DataSinkTask. createRuntimeContext()
DistributedRuntimeUDFContext
DataSourceTask. createRuntimeContext()
Methods in org.apache.flink.runtime.operators with parameters of type DistributedRuntimeUDFContext Modifier and Type Method Description protected <X> void
BatchTask. readAndSetBroadcastInput(int inputNum, String bcVarName, DistributedRuntimeUDFContext context, int superstep)
protected void
BatchTask. releaseBroadcastVariables(String bcVarName, int superstep, DistributedRuntimeUDFContext context)
-