public class DefaultMetricsMaster extends CoreMaster implements MetricsMaster, NoopJournaled
mBackupManager, mJournalSystem, mPort, mPrimarySelector, mSafeModeManager, mStartTimeMs
mClock, mJournal, mMasterContext
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.
|
close, createJournalContext, getDependencies, getExecutorService, getMasterContext, stop
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
createJournalContext, getMasterContext, getStandbyServices
applyAndJournal, processJournalEntry, resetState, restoreFromCheckpoint, writeToCheckpoint
getCheckpointName, restoreFromCheckpoint, writeToCheckpoint
getJournalEntryIterator
close, getDependencies, stop
getCheckpointName, getJournalEntryIterator, processJournalEntry, resetState, restoreFromCheckpoint, restoreFromCheckpoint, writeToCheckpoint, writeToCheckpoint
protected void addAggregator(MultiValueMetricsAggregator aggregator)
protected void registerThroughputGauge(String counterName, String throughputName)
counterName
- the counter to get value ofthroughputName
- the gauge throughput name to be registeredpublic String getName()
public Map<ServiceType,GrpcService> getServices()
getServices
in interface Server<Boolean>
public void start(Boolean isLeader) throws IOException
Server
start
in interface Server<Boolean>
start
in class AbstractMaster
isLeader
- the start optionsIOException
public void clientHeartbeat(String source, List<Metric> metrics)
MetricsMaster
clientHeartbeat
in interface MetricsMaster
source
- the metrics sourcemetrics
- client-side metricspublic MetricsMasterClientServiceHandler getMasterServiceHandler()
getMasterServiceHandler
in interface MetricsMaster
public void workerHeartbeat(String source, List<Metric> metrics)
MetricsMaster
workerHeartbeat
in interface MetricsMaster
source
- the source of the metricsmetrics
- the new worker metricspublic void clearMetrics()
MetricsMaster
clearMetrics
in interface MetricsMaster
public Map<String,MetricValue> getMetrics()
getMetrics
in interface MetricsMaster
Copyright © 2023. All Rights Reserved.