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	clientHeartbeat(String clientId, String hostname, List<Metric> metrics) Handles the client's heartbeat request for metrics collection.
MetricsMasterClientServiceHandler	getMasterServiceHandler()
void	workerHeartbeat(String hostname, List<Metric> metrics) Handles the worker heartbeat and puts the metrics from an instance with a hostname.

Methods inherited from interface alluxio.master.Master

createJournalContext

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

clientHeartbeat

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

Handles the client's heartbeat request for metrics collection.

Parameters:

clientId - the client id

hostname - the client hostname

metrics - client-side metrics

getMasterServiceHandler

MetricsMasterClientServiceHandler getMasterServiceHandler()

Returns:

the master service handler

workerHeartbeat

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

Handles the worker heartbeat and puts the metrics from an instance 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