org.apache.giraph.metrics

Class AggregatedMetrics

java.lang.Object

org.apache.giraph.metrics.AggregatedMetrics

public class AggregatedMetrics
extends Object

Map of a bunch of aggregated metrics

Constructor Summary

Constructors

Constructor and Description
AggregatedMetrics()

Method Summary

Modifier and Type	Method and Description
AggregatedMetrics	add(String name, double value, String hostnamePartitionId) Add value from hostname for a metric.
AggregatedMetrics	add(String name, long value, String hostnamePartitionId) Add value from hostname for a metric.
AggregatedMetrics	add(WorkerSuperstepMetrics workerMetrics, String hostname) Add metrics from worker.
AggregatedMetric	get(String name) Get AggregatedMetric with given name.
Map<String,AggregatedMetric<?>>	getAll() Get map of all aggregated metrics.
AggregatedMetrics	print(long superstep, PrintStream out) Print the aggregated metrics to the stream provided.

Methods inherited from class java.lang.Object

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

Constructor Detail

AggregatedMetrics

public AggregatedMetrics()

Method Detail

add

public AggregatedMetrics add(String name,
                             long value,
                             String hostnamePartitionId)

Add value from hostname for a metric.

Parameters:

name - String name of metric

value - long value to track

hostnamePartitionId - String host it came from

Returns:

this

add

public AggregatedMetrics add(String name,
                             double value,
                             String hostnamePartitionId)

Add value from hostname for a metric.

Parameters:

name - String name of metric

value - double value to track

hostnamePartitionId - String host it came from

Returns:

this

add

public AggregatedMetrics add(WorkerSuperstepMetrics workerMetrics,
                             String hostname)

Add metrics from worker.

Parameters:

workerMetrics - WorkerSuperstepMetrics from work

hostname - String hostname of worker

Returns:

this

print

public AggregatedMetrics print(long superstep,
                               PrintStream out)

Print the aggregated metrics to the stream provided.

Parameters:

superstep - long number of superstep.

out - PrintStream to write to.

Returns:

this

get

public AggregatedMetric get(String name)

Get AggregatedMetric with given name.

Parameters:

name - String metric to lookup.

Returns:

AggregatedMetric for given metric name.

getAll

public Map<String,AggregatedMetric<?>> getAll()

Get map of all aggregated metrics.

Returns:

Map of all the aggregated metrics.