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,
UserCodeClassLoader userCodeClassLoader,
MemoryManager memManager,
IOManager ioManager,
BroadcastVariableManager bcVarManager,
TaskStateManager taskStateManager,
GlobalAggregateManager aggregateManager,
AccumulatorRegistry accumulatorRegistry,
TaskKvStateRegistry kvStateRegistry,
InputSplitProvider splitProvider,
Map<String,Future<Path>> distCacheEntries,
ResultPartitionWriter[] writers,
IndexedInputGate[] inputGates,
TaskEventDispatcher taskEventDispatcher,
CheckpointResponder checkpointResponder,
TaskOperatorEventGateway operatorEventGateway,
TaskManagerRuntimeInfo taskManagerInfo,
TaskMetricGroup metrics,
Task containingTask,
ExternalResourceInfoProvider externalResourceInfoProvider) |
Modifier and Type | Method and Description |
---|---|
AccumulatorRegistry |
SavepointEnvironment.getAccumulatorRegistry() |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.