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, mPrimarySelector, mSafeModeManager, mStartTimeMs

Fields inherited from class alluxio.master.AbstractMaster

mClock, mJournal, mMasterContext

Method Summary

Modifier and Type	Method and Description
protected void	addAggregator(MultiValueMetricsAggregator aggregator)
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()
String	getName()
Map<ServiceType,GrpcService>	getServices()
protected void	registerThroughputGauge(String counterName, String throughputName) Registers the corresponding throughput of the given counter.
void	start(Boolean isLeader) Starts the Alluxio server.
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 class alluxio.master.AbstractMaster

close, createJournalContext, getDependencies, getExecutorService, getMasterContext, 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, 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, stop

Methods inherited from interface alluxio.master.journal.NoopJournaled

getCheckpointName, getJournalEntryIterator, processJournalEntry, resetState, restoreFromCheckpoint, writeToCheckpoint

Method Detail

addAggregator

protected void addAggregator(MultiValueMetricsAggregator aggregator)

registerThroughputGauge

protected void registerThroughputGauge(String counterName,
                                       String throughputName)

Registers the corresponding throughput of the given counter.

Parameters:

counterName - the counter to get value of

throughputName - the gauge throughput name to be registered

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 source,
                            List<Metric> metrics)

Description copied from interface: MetricsMaster

Handles the client's heartbeat request for metrics collection.

Specified by:

clientHeartbeat in interface MetricsMaster

Parameters:

source - the metrics source

metrics - client-side metrics

getMasterServiceHandler

public MetricsMasterClientServiceHandler getMasterServiceHandler()

Specified by:

getMasterServiceHandler in interface MetricsMaster

Returns:

the master service handler

workerHeartbeat

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

Description copied from interface: MetricsMaster

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

Specified by:

workerHeartbeat in interface MetricsMaster

Parameters:

source - the source of the metrics

metrics - the new worker metrics

clearMetrics

public void clearMetrics()

Description copied from interface: MetricsMaster

Clear metrics in the current master.

Specified by:

clearMetrics in interface MetricsMaster

getMetrics

public Map<String,MetricValue> getMetrics()

Specified by:

getMetrics in interface MetricsMaster

Returns:

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