Package | Description |
---|---|
org.apache.flink.runtime.accumulators | |
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.testingUtils |
Modifier and Type | Method and Description |
---|---|
static AccumulatorRegistry.Metric |
AccumulatorRegistry.Metric.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static AccumulatorRegistry.Metric[] |
AccumulatorRegistry.Metric.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
Map<AccumulatorRegistry.Metric,Accumulator<?,?>> |
AccumulatorSnapshot.deserializeFlinkAccumulators()
Gets the Flink (internal) accumulators values.
|
Constructor and Description |
---|
AccumulatorSnapshot(JobID jobID,
ExecutionAttemptID executionAttemptID,
Map<AccumulatorRegistry.Metric,Accumulator<?,?>> flinkAccumulators,
Map<String,Accumulator<?,?>> userAccumulators) |
Modifier and Type | Method and Description |
---|---|
Map<AccumulatorRegistry.Metric,Accumulator<?,?>> |
ExecutionJobVertex.getAggregatedMetricAccumulators() |
Map<ExecutionAttemptID,Map<AccumulatorRegistry.Metric,Accumulator<?,?>>> |
ExecutionGraph.getFlinkAccumulators()
Gets the internal flink accumulator map of maps which contains some metrics.
|
Map<AccumulatorRegistry.Metric,Accumulator<?,?>> |
Execution.getFlinkAccumulators() |
Modifier and Type | Method and Description |
---|---|
void |
Execution.setAccumulators(Map<AccumulatorRegistry.Metric,Accumulator<?,?>> flinkAccumulators,
Map<String,Accumulator<?,?>> userAccumulators)
Update accumulators (discarded when the Execution has already been terminated).
|
Modifier and Type | Method and Description |
---|---|
Map<ExecutionAttemptID,Map<AccumulatorRegistry.Metric,Accumulator<?,?>>> |
TestingJobManagerMessages.UpdatedAccumulators.flinkAccumulators() |
Constructor and Description |
---|
UpdatedAccumulators(JobID jobID,
Map<ExecutionAttemptID,Map<AccumulatorRegistry.Metric,Accumulator<?,?>>> flinkAccumulators,
Map<String,Accumulator<?,?>> userAccumulators) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.