| Package | Description |
|---|---|
| org.apache.flink.runtime.jobgraph.tasks | |
| org.apache.flink.runtime.operators | |
| org.apache.flink.runtime.taskmanager |
| Modifier and Type | Method and Description |
|---|---|
Environment |
AbstractInvokable.getEnvironment()
Returns the environment of this task.
|
| Modifier and Type | Method and Description |
|---|---|
void |
AbstractInvokable.setEnvironment(Environment environment)
Sets the environment of this task.
|
| Modifier and Type | Method and Description |
|---|---|
protected static void |
RegularPactTask.reportAndClearAccumulators(Environment env,
Map<String,org.apache.flink.api.common.accumulators.Accumulator<?,?>> accumulators,
ArrayList<ChainedDriver<?,?>> chainedTasks)
This method is called at the end of a task, receiving the accumulators of
the task and the chained tasks.
|
| Modifier and Type | Class and Description |
|---|---|
class |
RuntimeEnvironment
In implementation of the
Environment. |
Copyright © 2014–2015 The Apache Software Foundation. All rights reserved.