Package | Description |
---|---|
alluxio.grpc | |
alluxio.master.block | |
alluxio.master.block.meta |
Modifier and Type | Field and Description |
---|---|
static com.google.protobuf.Parser<StorageList> |
StorageList.PARSER
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
StorageList |
StorageList.Builder.build() |
StorageList |
StorageList.Builder.buildPartial() |
static StorageList |
StorageList.getDefaultInstance() |
StorageList |
StorageList.getDefaultInstanceForType() |
StorageList |
StorageList.Builder.getDefaultInstanceForType() |
StorageList |
RegisterWorkerPRequestOrBuilder.getLostStorageOrDefault(String key,
StorageList defaultValue)
the map of tier alias to a list of lost storage paths.
|
StorageList |
RegisterWorkerPRequest.getLostStorageOrDefault(String key,
StorageList defaultValue)
the map of tier alias to a list of lost storage paths.
|
StorageList |
RegisterWorkerPRequest.Builder.getLostStorageOrDefault(String key,
StorageList defaultValue)
the map of tier alias to a list of lost storage paths.
|
StorageList |
BlockHeartbeatPRequestOrBuilder.getLostStorageOrDefault(String key,
StorageList defaultValue)
the map of lost storage paths on all tiers
|
StorageList |
BlockHeartbeatPRequest.getLostStorageOrDefault(String key,
StorageList defaultValue)
the map of lost storage paths on all tiers
|
StorageList |
BlockHeartbeatPRequest.Builder.getLostStorageOrDefault(String key,
StorageList defaultValue)
the map of lost storage paths on all tiers
|
StorageList |
WorkerLostStorageInfoOrBuilder.getLostStorageOrDefault(String key,
StorageList defaultValue)
a map from tier alias to the lost storage paths
|
StorageList |
WorkerLostStorageInfo.getLostStorageOrDefault(String key,
StorageList defaultValue)
a map from tier alias to the lost storage paths
|
StorageList |
WorkerLostStorageInfo.Builder.getLostStorageOrDefault(String key,
StorageList defaultValue)
a map from tier alias to the lost storage paths
|
StorageList |
RegisterWorkerPRequestOrBuilder.getLostStorageOrThrow(String key)
the map of tier alias to a list of lost storage paths.
|
StorageList |
RegisterWorkerPRequest.getLostStorageOrThrow(String key)
the map of tier alias to a list of lost storage paths.
|
StorageList |
RegisterWorkerPRequest.Builder.getLostStorageOrThrow(String key)
the map of tier alias to a list of lost storage paths.
|
StorageList |
BlockHeartbeatPRequestOrBuilder.getLostStorageOrThrow(String key)
the map of lost storage paths on all tiers
|
StorageList |
BlockHeartbeatPRequest.getLostStorageOrThrow(String key)
the map of lost storage paths on all tiers
|
StorageList |
BlockHeartbeatPRequest.Builder.getLostStorageOrThrow(String key)
the map of lost storage paths on all tiers
|
StorageList |
WorkerLostStorageInfoOrBuilder.getLostStorageOrThrow(String key)
a map from tier alias to the lost storage paths
|
StorageList |
WorkerLostStorageInfo.getLostStorageOrThrow(String key)
a map from tier alias to the lost storage paths
|
StorageList |
WorkerLostStorageInfo.Builder.getLostStorageOrThrow(String key)
a map from tier alias to the lost storage paths
|
static StorageList |
StorageList.parseDelimitedFrom(InputStream input) |
static StorageList |
StorageList.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static StorageList |
StorageList.parseFrom(byte[] data) |
static StorageList |
StorageList.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static StorageList |
StorageList.parseFrom(ByteBuffer data) |
static StorageList |
StorageList.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static StorageList |
StorageList.parseFrom(com.google.protobuf.ByteString data) |
static StorageList |
StorageList.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static StorageList |
StorageList.parseFrom(com.google.protobuf.CodedInputStream input) |
static StorageList |
StorageList.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static StorageList |
StorageList.parseFrom(InputStream input) |
static StorageList |
StorageList.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
Map<String,StorageList> |
RegisterWorkerPRequestOrBuilder.getLostStorage()
Deprecated.
|
Map<String,StorageList> |
RegisterWorkerPRequest.getLostStorage()
Deprecated.
|
Map<String,StorageList> |
RegisterWorkerPRequest.Builder.getLostStorage()
Deprecated.
|
Map<String,StorageList> |
BlockHeartbeatPRequestOrBuilder.getLostStorage()
Deprecated.
|
Map<String,StorageList> |
BlockHeartbeatPRequest.getLostStorage()
Deprecated.
|
Map<String,StorageList> |
BlockHeartbeatPRequest.Builder.getLostStorage()
Deprecated.
|
Map<String,StorageList> |
WorkerLostStorageInfoOrBuilder.getLostStorage()
Deprecated.
|
Map<String,StorageList> |
WorkerLostStorageInfo.getLostStorage()
Deprecated.
|
Map<String,StorageList> |
WorkerLostStorageInfo.Builder.getLostStorage()
Deprecated.
|
Map<String,StorageList> |
RegisterWorkerPRequestOrBuilder.getLostStorageMap()
the map of tier alias to a list of lost storage paths.
|
Map<String,StorageList> |
RegisterWorkerPRequest.getLostStorageMap()
the map of tier alias to a list of lost storage paths.
|
Map<String,StorageList> |
RegisterWorkerPRequest.Builder.getLostStorageMap()
the map of tier alias to a list of lost storage paths.
|
Map<String,StorageList> |
BlockHeartbeatPRequestOrBuilder.getLostStorageMap()
the map of lost storage paths on all tiers
|
Map<String,StorageList> |
BlockHeartbeatPRequest.getLostStorageMap()
the map of lost storage paths on all tiers
|
Map<String,StorageList> |
BlockHeartbeatPRequest.Builder.getLostStorageMap()
the map of lost storage paths on all tiers
|
Map<String,StorageList> |
WorkerLostStorageInfoOrBuilder.getLostStorageMap()
a map from tier alias to the lost storage paths
|
Map<String,StorageList> |
WorkerLostStorageInfo.getLostStorageMap()
a map from tier alias to the lost storage paths
|
Map<String,StorageList> |
WorkerLostStorageInfo.Builder.getLostStorageMap()
a map from tier alias to the lost storage paths
|
Map<String,StorageList> |
RegisterWorkerPRequest.Builder.getMutableLostStorage()
Deprecated.
|
Map<String,StorageList> |
BlockHeartbeatPRequest.Builder.getMutableLostStorage()
Deprecated.
|
Map<String,StorageList> |
WorkerLostStorageInfo.Builder.getMutableLostStorage()
Deprecated.
|
com.google.protobuf.Parser<StorageList> |
StorageList.getParserForType() |
static com.google.protobuf.Parser<StorageList> |
StorageList.parser() |
Modifier and Type | Method and Description |
---|---|
StorageList |
RegisterWorkerPRequestOrBuilder.getLostStorageOrDefault(String key,
StorageList defaultValue)
the map of tier alias to a list of lost storage paths.
|
StorageList |
RegisterWorkerPRequest.getLostStorageOrDefault(String key,
StorageList defaultValue)
the map of tier alias to a list of lost storage paths.
|
StorageList |
RegisterWorkerPRequest.Builder.getLostStorageOrDefault(String key,
StorageList defaultValue)
the map of tier alias to a list of lost storage paths.
|
StorageList |
BlockHeartbeatPRequestOrBuilder.getLostStorageOrDefault(String key,
StorageList defaultValue)
the map of lost storage paths on all tiers
|
StorageList |
BlockHeartbeatPRequest.getLostStorageOrDefault(String key,
StorageList defaultValue)
the map of lost storage paths on all tiers
|
StorageList |
BlockHeartbeatPRequest.Builder.getLostStorageOrDefault(String key,
StorageList defaultValue)
the map of lost storage paths on all tiers
|
StorageList |
WorkerLostStorageInfoOrBuilder.getLostStorageOrDefault(String key,
StorageList defaultValue)
a map from tier alias to the lost storage paths
|
StorageList |
WorkerLostStorageInfo.getLostStorageOrDefault(String key,
StorageList defaultValue)
a map from tier alias to the lost storage paths
|
StorageList |
WorkerLostStorageInfo.Builder.getLostStorageOrDefault(String key,
StorageList defaultValue)
a map from tier alias to the lost storage paths
|
StorageList.Builder |
StorageList.Builder.mergeFrom(StorageList other) |
static StorageList.Builder |
StorageList.newBuilder(StorageList prototype) |
RegisterWorkerPRequest.Builder |
RegisterWorkerPRequest.Builder.putLostStorage(String key,
StorageList value)
the map of tier alias to a list of lost storage paths.
|
BlockHeartbeatPRequest.Builder |
BlockHeartbeatPRequest.Builder.putLostStorage(String key,
StorageList value)
the map of lost storage paths on all tiers
|
WorkerLostStorageInfo.Builder |
WorkerLostStorageInfo.Builder.putLostStorage(String key,
StorageList value)
a map from tier alias to the lost storage paths
|
Modifier and Type | Method and Description |
---|---|
RegisterWorkerPRequest.Builder |
RegisterWorkerPRequest.Builder.putAllLostStorage(Map<String,StorageList> values)
the map of tier alias to a list of lost storage paths.
|
BlockHeartbeatPRequest.Builder |
BlockHeartbeatPRequest.Builder.putAllLostStorage(Map<String,StorageList> values)
the map of lost storage paths on all tiers
|
WorkerLostStorageInfo.Builder |
WorkerLostStorageInfo.Builder.putAllLostStorage(Map<String,StorageList> values)
a map from tier alias to the lost storage paths
|
Modifier and Type | Method and Description |
---|---|
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.
|
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) |
void |
BlockMaster.workerRegister(long workerId,
List<String> storageTiers,
Map<String,Long> totalBytesOnTiers,
Map<String,Long> usedBytesOnTiers,
Map<Block.BlockLocation,List<Long>> currentBlocksOnLocation,
Map<String,StorageList> lostStorage,
RegisterWorkerPOptions options)
Updates metadata when a worker registers with the master.
|
void |
DefaultBlockMaster.workerRegister(long workerId,
List<String> storageTiers,
Map<String,Long> totalBytesOnTiers,
Map<String,Long> usedBytesOnTiers,
Map<Block.BlockLocation,List<Long>> currentBlocksOnLocation,
Map<String,StorageList> lostStorage,
RegisterWorkerPOptions options) |
Modifier and Type | Method and Description |
---|---|
void |
MasterWorkerInfo.addLostStorage(Map<String,StorageList> lostStorage)
Adds new worker lost storage paths.
|
Copyright © 2023. All Rights Reserved.