alluxio.master.metrics

Class DefaultMetricsMaster

java.lang.Object

alluxio.master.AbstractMaster

alluxio.master.CoreMaster

alluxio.master.metrics.DefaultMetricsMaster

All Implemented Interfaces:

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

public class DefaultMetricsMaster
extends CoreMaster
implements MetricsMaster, NoopJournaled

Default implementation of the metrics master.

Field Summary

Fields inherited from class alluxio.master.CoreMaster

mBackupManager, mJournalSystem, mPort, mSafeModeManager, mStartTimeMs

Fields inherited from class alluxio.master.AbstractMaster

mClock, mMasterContext

Method Summary

Modifier and Type	Method and Description
protected void	addAggregator(MultiValueMetricsAggregator aggregator)
protected void	addAggregator(SingleValueAggregator aggregator)
void	clientHeartbeat(String clientId, String hostname, List<Metric> metrics) Handles the client's heartbeat request for metrics collection.
MetricsMasterClientServiceHandler	getMasterServiceHandler()
String	getName()
Map<ServiceType,GrpcService>	getServices()
void	start(Boolean isLeader) Starts the Alluxio server.
void	workerHeartbeat(String hostname, List<Metric> metrics) Handles the worker heartbeat and puts the metrics from an instance with a hostname.

Methods inherited from class alluxio.master.AbstractMaster

close, createJournalContext, getDependencies, getExecutorService, stop

Methods inherited from class java.lang.Object

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

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, stop

Methods inherited from interface alluxio.master.journal.NoopJournaled

getCheckpointName, getJournalEntryIterator, processJournalEntry, resetState, restoreFromCheckpoint, writeToCheckpoint

Method Detail

addAggregator

protected void addAggregator(SingleValueAggregator aggregator)

addAggregator

protected void addAggregator(MultiValueMetricsAggregator aggregator)

getName

public String getName()

Specified by:

getName in interface Server<Boolean>

Returns:

the server's name

getServices

public Map<ServiceType,GrpcService> getServices()

Specified by:

getServices in interface Server<Boolean>

Returns:

a map from service names to gRPC serviced that serve RPCs for this server

start

public void start(Boolean isLeader)
           throws IOException

Description copied from interface: Server

Starts the Alluxio server.

Specified by:

start in interface Server<Boolean>

Overrides:

start in class AbstractMaster

Parameters:

isLeader - the start options

Throws:

IOException

clientHeartbeat

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

Description copied from interface: MetricsMaster

Handles the client's heartbeat request for metrics collection.

Specified by:

clientHeartbeat in interface MetricsMaster

Parameters:

clientId - the client id

hostname - the client hostname

metrics - client-side metrics

getMasterServiceHandler

public MetricsMasterClientServiceHandler getMasterServiceHandler()

Specified by:

getMasterServiceHandler in interface MetricsMaster

Returns:

the master service handler

workerHeartbeat

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

Description copied from interface: MetricsMaster

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.

Specified by:

workerHeartbeat in interface MetricsMaster

Parameters:

hostname - the hostname of the instance

metrics - the new worker metrics