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.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MetricsStore.ClusterCounterKey The key for cluster counter map.

Constructor Summary

Constructors

Constructor and Description
MetricsStore(java.time.Clock clock) Constructs a new MetricsStore.

Method Summary

Modifier and Type	Method and Description
void	clear() Clears all the metrics.
long	getLastClearTime()
void	initCounterKeys() Inits the metrics store.
void	putClientMetrics(String source, List<Metric> metrics) Put the metrics from a client with a source name.
void	putWorkerMetrics(String source, List<Metric> metrics) Put the metrics from a worker with a source name.

Methods inherited from class java.lang.Object

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

Constructor Detail

MetricsStore

public MetricsStore(java.time.Clock clock)

Constructs a new MetricsStore.

Parameters:

clock - the clock to get time of

Method Detail

putWorkerMetrics

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

Put the metrics from a worker with a source name.

Parameters:

source - the source name

metrics - the new worker metrics

putClientMetrics

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

Put the metrics from a client with a source name.

Parameters:

source - the source name

metrics - the new metrics

initCounterKeys

public void initCounterKeys()

Inits the metrics store. Defines the cluster metrics counters.

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.

getLastClearTime

public long getLastClearTime()

Returns:

the last metrics store clear time in milliseconds