alluxio.master.metrics

Interface MetricsMaster

All Superinterfaces:

Checkpointed, Journaled, JournalEntryIterable, Master, Server<Boolean>

All Known Implementing Classes:

DefaultMetricsMaster

public interface MetricsMaster
extends Master

Interface of the metrics master that aggregates the cluster-level metrics from workers and clients.

Method Summary

Modifier and Type	Method and Description
void	clearMetrics() Clear metrics in the current master.
void	clientHeartbeat(String source, List<Metric> metrics) Handles the client's heartbeat request for metrics collection.
MetricsMasterClientServiceHandler	getMasterServiceHandler()
Map<String,MetricValue>	getMetrics()
void	workerHeartbeat(String source, List<Metric> metrics) Handles the worker heartbeat and puts the metrics from an instance with a source name.

Methods inherited from interface alluxio.master.Master

createJournalContext, getMasterContext, getStandbyServices

Methods inherited from interface alluxio.master.journal.Journaled

applyAndJournal, processJournalEntry, resetState, restoreFromCheckpoint, writeToCheckpoint

Methods inherited from interface alluxio.master.journal.checkpoint.Checkpointed

getCheckpointName

Methods inherited from interface alluxio.master.journal.JournalEntryIterable

getJournalEntryIterator

Methods inherited from interface alluxio.Server

close, getDependencies, getName, getServices, start, stop

Method Detail

clearMetrics

void clearMetrics()

Clear metrics in the current master.

clientHeartbeat

void clientHeartbeat(String source,
                     List<Metric> metrics)

Handles the client's heartbeat request for metrics collection.

Parameters:

source - the metrics source

metrics - client-side metrics

getMasterServiceHandler

MetricsMasterClientServiceHandler getMasterServiceHandler()

Returns:

the master service handler

getMetrics

Map<String,MetricValue> getMetrics()

Returns:

all metrics stored in the current master in a map from metric name to corresponding metric value.

workerHeartbeat

void workerHeartbeat(String source,
                     List<Metric> metrics)

Handles the worker heartbeat and puts the metrics from an instance with a source name.

Parameters:

source - the source of the metrics

metrics - the new worker metrics