alluxio.metrics.aggregator

Class SumInstancesAggregator

java.lang.Object

alluxio.metrics.aggregator.SumInstancesAggregator

All Implemented Interfaces:

MetricsAggregator, SingleValueAggregator

public class SumInstancesAggregator
extends Object
implements SingleValueAggregator

An aggregator that sums the metric values from all the metrics of a given instance type and metric name. The aggregated metric will have name of pattern cluster.metric_name.

Constructor Summary

Constructors

Constructor and Description
SumInstancesAggregator(String aggregationName, MetricsSystem.InstanceType instanceType, String metricName) Creates an instance of SumInstancesAggregator.

Method Summary

Modifier and Type	Method and Description
List<MetricsFilter>	getFilters()
MetricsSystem.InstanceType	getInstanceType()
String	getName()
long	getValue(Map<MetricsFilter,Set<Metric>> map) Gets the aggregated value from the filtered metrics.

Methods inherited from class java.lang.Object

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

Constructor Detail

SumInstancesAggregator

public SumInstancesAggregator(String aggregationName,
                              MetricsSystem.InstanceType instanceType,
                              String metricName)

Creates an instance of SumInstancesAggregator.

Parameters:

aggregationName - the aggregation name

instanceType - instance type which can be worker or client

metricName - the metric name

Method Detail

getInstanceType

public MetricsSystem.InstanceType getInstanceType()

Returns:

the instance type to aggregate on

getName

public String getName()

Specified by:

getName in interface MetricsAggregator

Returns:

the name of the aggregated metric

getFilters

public List<MetricsFilter> getFilters()

Specified by:

getFilters in interface MetricsAggregator

Returns:

the filters for matching the instance metrics

getValue

public long getValue(Map<MetricsFilter,Set<Metric>> map)

Description copied from interface: SingleValueAggregator

Gets the aggregated value from the filtered metrics. The values of map will be the filtered metrics using the MetricsFilter defined in MetricsAggregator.getFilters().

Specified by:

getValue in interface SingleValueAggregator

Parameters:

map - a map of MetricsFilter to the set of metrics that it filter to

Returns:

the aggregated value