Package | Description |
---|---|
alluxio.client.block.policy | |
alluxio.client.block.policy.options | |
alluxio.client.file | |
alluxio.job.util |
Modifier and Type | Method and Description |
---|---|
protected BlockWorkerInfo |
CapacityBasedDeterministicHashPolicy.getRandomCandidate(List<BlockWorkerInfo> candidates) |
Modifier and Type | Method and Description |
---|---|
protected BlockWorkerInfo |
CapacityBasedDeterministicHashPolicy.getRandomCandidate(List<BlockWorkerInfo> candidates) |
Modifier and Type | Method and Description |
---|---|
Iterable<BlockWorkerInfo> |
GetWorkerOptions.getBlockWorkerInfos() |
Modifier and Type | Method and Description |
---|---|
GetWorkerOptions |
GetWorkerOptions.setBlockWorkerInfos(List<BlockWorkerInfo> blockWorkerInfos) |
Modifier and Type | Method and Description |
---|---|
List<BlockWorkerInfo> |
FileSystemContext.getCachedWorkers()
Gets the cached worker information list.
|
Modifier and Type | Method and Description |
---|---|
static BlockWorkerInfo |
JobUtils.getWorkerWithMostBlocks(List<BlockWorkerInfo> workers,
List<FileBlockInfo> fileBlockInfos)
Returns whichever specified worker stores the most blocks from the block info list.
|
Modifier and Type | Method and Description |
---|---|
static BlockWorkerInfo |
JobUtils.getWorkerWithMostBlocks(List<BlockWorkerInfo> workers,
List<FileBlockInfo> fileBlockInfos)
Returns whichever specified worker stores the most blocks from the block info list.
|
Copyright © 2023. All Rights Reserved.