org.apache.beam.runners.flink.metrics

Class MetricsAccumulator

java.lang.Object

org.apache.beam.runners.flink.metrics.MetricsAccumulator

All Implemented Interfaces:

java.io.Serializable, java.lang.Cloneable, org.apache.flink.api.common.accumulators.Accumulator<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap>, org.apache.flink.api.common.accumulators.SimpleAccumulator<org.apache.beam.runners.core.metrics.MetricsContainerStepMap>

public class MetricsAccumulator
extends java.lang.Object
implements org.apache.flink.api.common.accumulators.SimpleAccumulator<org.apache.beam.runners.core.metrics.MetricsContainerStepMap>

Accumulator of 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.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
MetricsAccumulator()

Method Summary

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()

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MetricsAccumulator

public MetricsAccumulator()

Method Detail

add

public void add(org.apache.beam.runners.core.metrics.MetricsContainerStepMap value)

Specified by:

add in interface org.apache.flink.api.common.accumulators.Accumulator<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap>

getLocalValue

public org.apache.beam.runners.core.metrics.MetricsContainerStepMap getLocalValue()

Specified by:

getLocalValue in interface org.apache.flink.api.common.accumulators.Accumulator<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap>

resetLocal

public void resetLocal()

Specified by:

resetLocal in interface org.apache.flink.api.common.accumulators.Accumulator<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap>

merge

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)

Specified by:

merge in interface org.apache.flink.api.common.accumulators.Accumulator<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap>

clone

public org.apache.flink.api.common.accumulators.Accumulator<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap> clone()

Specified by:

clone in interface org.apache.flink.api.common.accumulators.Accumulator<org.apache.beam.runners.core.metrics.MetricsContainerStepMap,org.apache.beam.runners.core.metrics.MetricsContainerStepMap>

Overrides:

clone in class java.lang.Object