public class MetricsAccumulator
extends java.lang.Object
implements org.apache.flink.api.common.accumulators.SimpleAccumulator<org.apache.beam.runners.core.metrics.MetricsContainerStepMap>
MetricsContainerStepMap
. This accumulator will only be reported to Flink
when the job ends. This avoids the runtime overhead for accumulators which are continously sent
to the job manager.Constructor and Description |
---|
MetricsAccumulator() |
Modifier and Type | Method and Description |
---|---|
void |
add(org.apache.beam.runners.core.metrics.MetricsContainerStepMap value) |
org.apache.flink.api.common.accumulators.Accumulator<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap> |
clone() |
org.apache.beam.runners.core.metrics.MetricsContainerStepMap |
getLocalValue() |
void |
merge(org.apache.flink.api.common.accumulators.Accumulator<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap> other) |
void |
resetLocal() |
public void add(org.apache.beam.runners.core.metrics.MetricsContainerStepMap value)
add
in interface org.apache.flink.api.common.accumulators.Accumulator<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap>
public org.apache.beam.runners.core.metrics.MetricsContainerStepMap getLocalValue()
getLocalValue
in interface org.apache.flink.api.common.accumulators.Accumulator<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap>
public void resetLocal()
resetLocal
in interface org.apache.flink.api.common.accumulators.Accumulator<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap>
public void merge(org.apache.flink.api.common.accumulators.Accumulator<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap> other)
merge
in interface org.apache.flink.api.common.accumulators.Accumulator<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap>
public org.apache.flink.api.common.accumulators.Accumulator<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap> clone()
clone
in interface org.apache.flink.api.common.accumulators.Accumulator<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap>
clone
in class java.lang.Object