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.

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