org.apache.giraph.metrics

Class AggregatedMetric<T extends Number>

java.lang.Object

org.apache.giraph.metrics.AggregatedMetric<T>

Type Parameters:

T - value type

Direct Known Subclasses:

AggregatedMetricDouble, AggregatedMetricLong

public abstract class AggregatedMetric<T extends Number>
extends Object

An aggregator over metrics from multiple hosts. Computes min, max, and mean.

Field Summary

Fields

Modifier and Type	Field and Description
protected long	count Number of values seen
protected ValueWithHostname<T>	max Maximum value seen with the host that it came from
protected ValueWithHostname<T>	min Minimum value seen with the host that it came from
protected T	sum Total of all the values seen

Constructor Summary

Constructors

Constructor and Description
AggregatedMetric()

Method Summary

Modifier and Type	Method and Description
abstract void	addItem(T value, String hostnamePartitionId) Add another item to the aggregation.
long	count() Get number of values seen
boolean	hasData() Whether this AggregatedMetric has any data.
ValueWithHostname<T>	max() Get maximum value together with host it came from.
abstract double	mean() Get average of all the values
ValueWithHostname<T>	min() Get minimum value together with host it came from.
T	sum() Get total of all the values seen

Methods inherited from class java.lang.Object

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

Field Detail

min

protected ValueWithHostname<T extends Number> min

Minimum value seen with the host that it came from

max

protected ValueWithHostname<T extends Number> max

Maximum value seen with the host that it came from

sum

protected T extends Number sum

Total of all the values seen

count

protected long count

Number of values seen

Constructor Detail

AggregatedMetric

public AggregatedMetric()

Method Detail

addItem

public abstract void addItem(T value,
                             String hostnamePartitionId)

Add another item to the aggregation.

Parameters:

value - value to add

hostnamePartitionId - String hostname it came from

hasData

public boolean hasData()

Whether this AggregatedMetric has any data.

Returns:

true if we have any data.

min

public ValueWithHostname<T> min()

Get minimum value together with host it came from.

Returns:

ValueWithHostname for minimum

max

public ValueWithHostname<T> max()

Get maximum value together with host it came from.

Returns:

ValueWithHostname for maximum

sum

public T sum()

Get total of all the values seen

Returns:

total of values seen

mean

public abstract double mean()

Get average of all the values

Returns:

computed average of all the values

count

public long count()

Get number of values seen

Returns:

count of values