Package | Description |
---|---|
alluxio.master.block | |
alluxio.master.metrics | |
alluxio.metrics | |
alluxio.metrics.aggregator |
Modifier and Type | Method and Description |
---|---|
Command |
DefaultBlockMaster.workerHeartbeat(long workerId,
Map<String,Long> capacityBytesOnTiers,
Map<String,Long> usedBytesOnTiers,
List<Long> removedBlockIds,
Map<Block.BlockLocation,List<Long>> addedBlocks,
Map<String,StorageList> lostStorage,
List<Metric> metrics) |
Command |
BlockMaster.workerHeartbeat(long workerId,
Map<String,Long> capacityBytesOnTiers,
Map<String,Long> usedBytesOnTiers,
List<Long> removedBlockIds,
Map<Block.BlockLocation,List<Long>> addedBlocks,
Map<String,StorageList> lostStorage,
List<Metric> metrics)
Updates metadata when a worker periodically heartbeats with the master.
|
Modifier and Type | Method and Description |
---|---|
void |
DefaultMetricsMaster.clientHeartbeat(String source,
List<Metric> metrics) |
void |
MetricsMaster.clientHeartbeat(String source,
List<Metric> metrics)
Handles the client's heartbeat request for metrics collection.
|
void |
MetricsStore.putClientMetrics(String source,
List<Metric> metrics)
Put the metrics from a client with a source name.
|
void |
MetricsStore.putWorkerMetrics(String source,
List<Metric> metrics)
Put the metrics from a worker with a source name.
|
void |
DefaultMetricsMaster.workerHeartbeat(String source,
List<Metric> metrics) |
void |
MetricsMaster.workerHeartbeat(String source,
List<Metric> metrics)
Handles the worker heartbeat and puts the metrics from an instance with a source name.
|
Modifier and Type | Method and Description |
---|---|
static Metric |
Metric.from(String fullName,
double value,
MetricType metricType)
Creates the metric from the full name and the value.
|
static Metric |
Metric.fromProto(Metric metric)
Constructs the metric object from the proto format.
|
static Metric |
MetricsSystem.getMetricValue(String fullName)
Gets metric with the given full metric name.
|
Modifier and Type | Method and Description |
---|---|
static Map<String,Set<Metric>> |
MetricsSystem.getMasterMetrics(Set<String> metricNames)
Gets all the master metrics belongs to the given metric names.
|
Modifier and Type | Method and Description |
---|---|
long |
SingleValueAggregator.getValue(Map<MetricsFilter,Set<Metric>> map)
Gets the aggregated value from the filtered metrics.
|
Map<String,Long> |
MultiValueMetricsAggregator.updateValues(Set<Metric> map)
Updates the aggregated values from the filtered metrics.
|
Modifier and Type | Method and Description |
---|---|
Map<String,Long> |
SingleTagValueAggregator.updateValues(Set<Metric> set) |
Copyright © 2023. All Rights Reserved.