alluxio.master.metrics

Class DefaultMetricsMaster

java.lang.Object

alluxio.master.AbstractMaster

alluxio.master.metrics.DefaultMetricsMaster

All Implemented Interfaces:

JournalEntryIterable, JournalEntryStateMachine, Master, MetricsMaster, Server<Boolean>

public class DefaultMetricsMaster
extends AbstractMaster
implements MetricsMaster

Default implementation of the metrics master.

Field Summary

Fields inherited from class alluxio.master.AbstractMaster

mBackupManager, mClock, mPauseStateLock, mSafeModeManager, mStateChangeLock

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.
Iterator<Journal.JournalEntry>	getJournalEntryIterator()
MetricsMasterClientServiceHandler	getMasterServiceHandler()
String	getName()
Map<String,org.apache.thrift.TProcessor>	getServices()
void	processJournalEntry(Journal.JournalEntry entry) Applies a journal entry to the state machine.
void	resetState() Resets the journaled internal state of the state machine.
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

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.Server

getDependencies, stop

Method Detail

addAggregator

protected void addAggregator(SingleValueAggregator aggregator)

addAggregator

protected void addAggregator(MultiValueMetricsAggregator aggregator)

getName

public String getName()

Specified by:

getName in interface JournalEntryStateMachine

Specified by:

getName in interface Server<Boolean>

Returns:

the name of this journal entry state machine

processJournalEntry

public void processJournalEntry(Journal.JournalEntry entry)
                         throws IOException

Description copied from interface: JournalEntryStateMachine

Applies a journal entry to the state machine.

Specified by:

processJournalEntry in interface JournalEntryStateMachine

Parameters:

entry - the entry to process to update the state of the state machine

Throws:

IOException

resetState

public void resetState()

Description copied from interface: JournalEntryStateMachine

Resets the journaled internal state of the state machine.

Specified by:

resetState in interface JournalEntryStateMachine

getJournalEntryIterator

public Iterator<Journal.JournalEntry> getJournalEntryIterator()

Specified by:

getJournalEntryIterator in interface JournalEntryIterable

Returns:

an Iterator that iterates all the journal entries

getServices

public Map<String,org.apache.thrift.TProcessor> getServices()

Specified by:

getServices in interface Server<Boolean>

Returns:

a map from service names to TProcessors 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