Package | Description |
---|---|
org.apache.flink.runtime.execution | |
org.apache.flink.runtime.taskmanager | |
org.apache.flink.state.api.runtime |
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,
GlobalAggregateManager aggregateManager,
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) |
Modifier and Type | Method and Description |
---|---|
AccumulatorRegistry |
SavepointEnvironment.getAccumulatorRegistry() |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.