Package | Description |
---|---|
org.apache.flink.runtime.execution | |
org.apache.flink.runtime.taskmanager |
Modifier and Type | Method and Description |
---|---|
AccumulatorRegistry |
Environment.getAccumulatorRegistry()
Return the registry for accumulators which are periodically sent to the job manager.
|
Modifier and Type | Method and Description |
---|---|
AccumulatorRegistry |
RuntimeEnvironment.getAccumulatorRegistry() |
AccumulatorRegistry |
Task.getAccumulatorRegistry() |
Constructor and Description |
---|
RuntimeEnvironment(JobID jobId,
JobVertexID jobVertexId,
ExecutionAttemptID executionId,
ExecutionConfig executionConfig,
TaskInfo taskInfo,
Configuration jobConfiguration,
Configuration taskConfiguration,
ClassLoader userCodeClassLoader,
MemoryManager memManager,
IOManager ioManager,
BroadcastVariableManager bcVarManager,
TaskStateManager taskStateManager,
AccumulatorRegistry accumulatorRegistry,
TaskKvStateRegistry kvStateRegistry,
InputSplitProvider splitProvider,
Map<String,Future<Path>> distCacheEntries,
ResultPartitionWriter[] writers,
InputGate[] inputGates,
TaskEventDispatcher taskEventDispatcher,
CheckpointResponder checkpointResponder,
TaskManagerRuntimeInfo taskManagerInfo,
TaskMetricGroup metrics,
Task containingTask) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.