alluxio.master.metrics

Class MetricsStore

java.lang.Object

alluxio.master.metrics.MetricsStore

@ThreadSafe
public class MetricsStore
extends Object

A store of metrics containing the metrics collected from workers and clients.

Constructor Summary

Constructors

Constructor and Description
MetricsStore()

Method Summary

Modifier and Type	Method and Description
void	clear() Clears all the metrics.
Set<Metric>	getMetricsByInstanceTypeAndName(MetricsSystem.InstanceType instanceType, String name) Gets all the metrics by instance type and the metric name.
void	putClientMetrics(String hostname, String clientId, List<Metric> metrics) Put the metrics from a client with a hostname and a client id.
void	putWorkerMetrics(String hostname, List<Metric> metrics) Put the metrics from a worker with a hostname.

Methods inherited from class java.lang.Object

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

Constructor Detail

MetricsStore

public MetricsStore()

Method Detail

putWorkerMetrics

public void putWorkerMetrics(String hostname,
                             List<Metric> metrics)

Put the metrics from a worker with a hostname. If all the old metrics associated with this instance will be removed and then replaced by the latest.

Parameters:

hostname - the hostname of the instance

metrics - the new worker metrics

putClientMetrics

public void putClientMetrics(String hostname,
                             String clientId,
                             List<Metric> metrics)

Put the metrics from a client with a hostname and a client id. If all the old metrics associated with this instance will be removed and then replaced by the latest.

Parameters:

hostname - the hostname of the client

clientId - the id of the client

metrics - the new metrics

getMetricsByInstanceTypeAndName

public Set<Metric> getMetricsByInstanceTypeAndName(MetricsSystem.InstanceType instanceType,
                                                   String name)

Gets all the metrics by instance type and the metric name. The supported instance types are worker and client.

Parameters:

instanceType - the instance type

name - the metric name

Returns:

the set of matched metrics

clear

public void clear()

Clears all the metrics. This method should only be called when starting the DefaultMetricsMaster and before starting the metrics updater to avoid conflicts with other methods in this class which updates or accesses the metrics inside metrics sets.