Package | Description |
---|---|
org.apache.flink.runtime.iterative.task | |
org.apache.flink.runtime.operators |
Modifier and Type | Method and Description |
---|---|
DistributedRuntimeUDFContext |
AbstractIterativeTask.createRuntimeContext(MetricGroup metrics) |
Modifier and Type | Field and Description |
---|---|
protected DistributedRuntimeUDFContext |
BatchTask.runtimeUdfContext
The udf's runtime context.
|
Modifier and Type | Method and Description |
---|---|
DistributedRuntimeUDFContext |
DataSinkTask.createRuntimeContext() |
DistributedRuntimeUDFContext |
DataSourceTask.createRuntimeContext() |
DistributedRuntimeUDFContext |
BatchTask.createRuntimeContext(MetricGroup metrics) |
Modifier and Type | Method and Description |
---|---|
protected <X> void |
BatchTask.readAndSetBroadcastInput(int inputNum,
String bcVarName,
DistributedRuntimeUDFContext context,
int superstep) |
protected void |
BatchTask.releaseBroadcastVariables(String bcVarName,
int superstep,
DistributedRuntimeUDFContext context) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.