Package | Description |
---|---|
alluxio.master.block | |
alluxio.master.metastore | |
alluxio.master.metastore.heap | |
alluxio.master.metastore.rocks | |
alluxio.proto.meta | |
alluxio.util.proto |
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.
|
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) |
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.
|
Modifier and Type | Method and Description |
---|---|
List<Block.BlockLocation> |
BlockMetaStore.getLocations(long id)
Gets locations for a block.
|
Modifier and Type | Method and Description |
---|---|
void |
BlockMetaStore.addLocation(long id,
Block.BlockLocation location)
Adds a new block location.
|
Modifier and Type | Field and Description |
---|---|
TwoKeyConcurrentMap<Long,Long,Block.BlockLocation,Map<Long,Block.BlockLocation>> |
HeapBlockMetaStore.mBlockLocations |
TwoKeyConcurrentMap<Long,Long,Block.BlockLocation,Map<Long,Block.BlockLocation>> |
HeapBlockMetaStore.mBlockLocations |
Modifier and Type | Method and Description |
---|---|
List<Block.BlockLocation> |
HeapBlockMetaStore.getLocations(long blockid) |
Modifier and Type | Method and Description |
---|---|
void |
HeapBlockMetaStore.addLocation(long blockId,
Block.BlockLocation location) |
Modifier and Type | Method and Description |
---|---|
List<Block.BlockLocation> |
RocksBlockMetaStore.getLocations(long id) |
Modifier and Type | Method and Description |
---|---|
void |
RocksBlockMetaStore.addLocation(long id,
Block.BlockLocation location) |
Modifier and Type | Field and Description |
---|---|
static com.google.protobuf.Parser<Block.BlockLocation> |
Block.BlockLocation.PARSER
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Block.BlockLocation |
Block.BlockLocation.Builder.build() |
Block.BlockLocation |
Block.BlockLocation.Builder.buildPartial() |
static Block.BlockLocation |
Block.BlockLocation.getDefaultInstance() |
Block.BlockLocation |
Block.BlockLocation.getDefaultInstanceForType() |
Block.BlockLocation |
Block.BlockLocation.Builder.getDefaultInstanceForType() |
static Block.BlockLocation |
Block.BlockLocation.parseDelimitedFrom(InputStream input) |
static Block.BlockLocation |
Block.BlockLocation.parseDelimitedFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Block.BlockLocation |
Block.BlockLocation.parseFrom(byte[] data) |
static Block.BlockLocation |
Block.BlockLocation.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Block.BlockLocation |
Block.BlockLocation.parseFrom(ByteBuffer data) |
static Block.BlockLocation |
Block.BlockLocation.parseFrom(ByteBuffer data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Block.BlockLocation |
Block.BlockLocation.parseFrom(com.google.protobuf.ByteString data) |
static Block.BlockLocation |
Block.BlockLocation.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Block.BlockLocation |
Block.BlockLocation.parseFrom(com.google.protobuf.CodedInputStream input) |
static Block.BlockLocation |
Block.BlockLocation.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static Block.BlockLocation |
Block.BlockLocation.parseFrom(InputStream input) |
static Block.BlockLocation |
Block.BlockLocation.parseFrom(InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
com.google.protobuf.Parser<Block.BlockLocation> |
Block.BlockLocation.getParserForType() |
static com.google.protobuf.Parser<Block.BlockLocation> |
Block.BlockLocation.parser() |
Modifier and Type | Method and Description |
---|---|
Block.BlockLocation.Builder |
Block.BlockLocation.Builder.mergeFrom(Block.BlockLocation other) |
static Block.BlockLocation.Builder |
Block.BlockLocation.newBuilder(Block.BlockLocation prototype) |
Modifier and Type | Method and Description |
---|---|
static Block.BlockLocation |
BlockLocationUtils.getCached(Block.BlockLocation blockLocation)
Get a shared grpc block location object.
|
static Block.BlockLocation |
BlockLocationUtils.getCached(long workerId,
String tierAlias,
String mediumType)
Get a shared grpc block location object.
|
Modifier and Type | Method and Description |
---|---|
static Block.BlockLocation |
BlockLocationUtils.getCached(Block.BlockLocation blockLocation)
Get a shared grpc block location object.
|
Copyright © 2023. All Rights Reserved.