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 |
---|---|
Set<Metric> |
MetricsStore.getMetricsByInstanceTypeAndName(MetricsSystem.InstanceType instanceType,
String name)
Gets all the metrics by instance type and the metric name.
|
Modifier and Type | Method and Description |
---|---|
void |
DefaultMetricsMaster.clientHeartbeat(String clientId,
String hostname,
List<Metric> metrics) |
void |
MetricsMaster.clientHeartbeat(String clientId,
String hostname,
List<Metric> metrics)
Handles the client's heartbeat request for metrics collection.
|
void |
MetricsStore.putClientMetrics(String hostname,
String clientId,
List<Metric> metrics)
Put the metrics from a client with a hostname and a client id.
|
void |
MetricsStore.putWorkerMetrics(String hostname,
List<Metric> metrics)
Put the metrics from a worker with a hostname.
|
void |
DefaultMetricsMaster.workerHeartbeat(String hostname,
List<Metric> metrics) |
void |
MetricsMaster.workerHeartbeat(String hostname,
List<Metric> metrics)
Handles the worker heartbeat and puts the metrics from an instance with a hostname.
|
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.
|
Modifier and Type | Method and Description |
---|---|
static List<Metric> |
MetricsSystem.allClientMetrics() |
static List<Metric> |
MetricsSystem.allMasterMetrics() |
static List<Metric> |
MetricsSystem.allWorkerMetrics() |
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(Map<MetricsFilter,Set<Metric>> map)
Updates the aggregated values from the filtered metrics.
|
Modifier and Type | Method and Description |
---|---|
long |
SumInstancesAggregator.getValue(Map<MetricsFilter,Set<Metric>> map) |
Map<String,Long> |
SingleTagValueAggregator.updateValues(Map<MetricsFilter,Set<Metric>> map) |
Copyright © 2023. All Rights Reserved.