Package | Description |
---|---|
alluxio.grpc | |
alluxio.metrics | |
alluxio.worker.block |
Modifier and Type | Field and Description |
---|---|
static com.google.protobuf.Parser<Metric> |
Metric.PARSER
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Metric |
Metric.Builder.build() |
Metric |
Metric.Builder.buildPartial() |
static Metric |
Metric.getDefaultInstance() |
Metric |
Metric.getDefaultInstanceForType() |
Metric |
Metric.Builder.getDefaultInstanceForType() |
Metric |
BlockHeartbeatPOptions.getMetrics(int index)
repeated .alluxio.grpc.Metric metrics = 1; |
Metric |
BlockHeartbeatPOptions.Builder.getMetrics(int index)
repeated .alluxio.grpc.Metric metrics = 1; |
Metric |
ClientMetricsOrBuilder.getMetrics(int index)
repeated .alluxio.grpc.Metric metrics = 2; |
Metric |
ClientMetrics.getMetrics(int index)
repeated .alluxio.grpc.Metric metrics = 2; |
Metric |
ClientMetrics.Builder.getMetrics(int index)
repeated .alluxio.grpc.Metric metrics = 2; |
Metric |
BlockHeartbeatPOptionsOrBuilder.getMetrics(int index)
repeated .alluxio.grpc.Metric metrics = 1; |
static Metric |
Metric.parseDelimitedFrom(InputStream input) |
static Metric |
Metric.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Metric |
Metric.parseFrom(byte[] data) |
static Metric |
Metric.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Metric |
Metric.parseFrom(ByteBuffer data) |
static Metric |
Metric.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Metric |
Metric.parseFrom(com.google.protobuf.ByteString data) |
static Metric |
Metric.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Metric |
Metric.parseFrom(com.google.protobuf.CodedInputStream input) |
static Metric |
Metric.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Metric |
Metric.parseFrom(InputStream input) |
static Metric |
Metric.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
List<Metric> |
BlockHeartbeatPOptions.getMetricsList()
repeated .alluxio.grpc.Metric metrics = 1; |
List<Metric> |
BlockHeartbeatPOptions.Builder.getMetricsList()
repeated .alluxio.grpc.Metric metrics = 1; |
List<Metric> |
ClientMetricsOrBuilder.getMetricsList()
repeated .alluxio.grpc.Metric metrics = 2; |
List<Metric> |
ClientMetrics.getMetricsList()
repeated .alluxio.grpc.Metric metrics = 2; |
List<Metric> |
ClientMetrics.Builder.getMetricsList()
repeated .alluxio.grpc.Metric metrics = 2; |
List<Metric> |
BlockHeartbeatPOptionsOrBuilder.getMetricsList()
repeated .alluxio.grpc.Metric metrics = 1; |
com.google.protobuf.Parser<Metric> |
Metric.getParserForType() |
static com.google.protobuf.Parser<Metric> |
Metric.parser() |
Modifier and Type | Method and Description |
---|---|
BlockHeartbeatPOptions.Builder |
BlockHeartbeatPOptions.Builder.addMetrics(int index,
Metric value)
repeated .alluxio.grpc.Metric metrics = 1; |
ClientMetrics.Builder |
ClientMetrics.Builder.addMetrics(int index,
Metric value)
repeated .alluxio.grpc.Metric metrics = 2; |
BlockHeartbeatPOptions.Builder |
BlockHeartbeatPOptions.Builder.addMetrics(Metric value)
repeated .alluxio.grpc.Metric metrics = 1; |
ClientMetrics.Builder |
ClientMetrics.Builder.addMetrics(Metric value)
repeated .alluxio.grpc.Metric metrics = 2; |
Metric.Builder |
Metric.Builder.mergeFrom(Metric other) |
static Metric.Builder |
Metric.newBuilder(Metric prototype) |
BlockHeartbeatPOptions.Builder |
BlockHeartbeatPOptions.Builder.setMetrics(int index,
Metric value)
repeated .alluxio.grpc.Metric metrics = 1; |
ClientMetrics.Builder |
ClientMetrics.Builder.setMetrics(int index,
Metric value)
repeated .alluxio.grpc.Metric metrics = 2; |
Modifier and Type | Method and Description |
---|---|
BlockHeartbeatPOptions.Builder |
BlockHeartbeatPOptions.Builder.addAllMetrics(Iterable<? extends Metric> values)
repeated .alluxio.grpc.Metric metrics = 1; |
ClientMetrics.Builder |
ClientMetrics.Builder.addAllMetrics(Iterable<? extends Metric> values)
repeated .alluxio.grpc.Metric metrics = 2; |
Modifier and Type | Method and Description |
---|---|
Metric |
Metric.toProto() |
Modifier and Type | Method and Description |
---|---|
static List<Metric> |
MetricsSystem.reportClientMetrics() |
static List<Metric> |
MetricsSystem.reportWorkerMetrics() |
Modifier and Type | Method and Description |
---|---|
static Metric |
Metric.fromProto(Metric metric)
Constructs the metric object from the proto format.
|
Modifier and Type | Method and Description |
---|---|
Command |
BlockMasterClient.heartbeat(long workerId,
Map<String,Long> capacityBytesOnTiers,
Map<String,Long> usedBytesOnTiers,
List<Long> removedBlocks,
Map<BlockStoreLocation,List<Long>> addedBlocks,
Map<String,List<String>> lostStorage,
List<Metric> metrics)
The method the worker should periodically execute to heartbeat back to the master.
|
Copyright © 2023. All Rights Reserved.