Package org.apache.beam.sdk.metrics

Class DelegatingDistribution

java.lang.Object

org.apache.beam.sdk.metrics.DelegatingDistribution

All Implemented Interfaces:

Serializable, Distribution, Metric

@Internal
public class DelegatingDistribution
extends Object
implements Metric, Distribution, Serializable

Implementation of Distribution that delegates to the instance for the current context.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
DelegatingDistribution(MetricName name)
DelegatingDistribution(MetricName name, boolean processWideContainer)

Method Summary

Modifier and Type	Method	Description
MetricName	getName()	The MetricName given to this metric.
void	update(long value)	Add an observation to this distribution.
void	update(long sum, long count, long min, long max)

Methods inherited from class java.lang.Object

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

Constructor Details

DelegatingDistribution

public DelegatingDistribution(MetricName name)

DelegatingDistribution

public DelegatingDistribution(MetricName name,
 boolean processWideContainer)

Method Details

update

public void update(long value)

Description copied from interface: Distribution

Add an observation to this distribution.

Specified by:

update in interface Distribution

update

public void update(long sum,
 long count,
 long min,
 long max)

Specified by:

update in interface Distribution

getName

public MetricName getName()

Description copied from interface: Metric

The MetricName given to this metric.

Specified by:

getName in interface Metric