Package | Description |
---|---|
alluxio.client.block.policy | |
alluxio.client.block.policy.options | |
alluxio.stress.cli.client |
Modifier and Type | Method and Description |
---|---|
Optional<WorkerNetAddress> |
CapacityBasedDeterministicHashPolicy.getWorker(GetWorkerOptions options) |
Optional<WorkerNetAddress> |
RoundRobinPolicy.getWorker(GetWorkerOptions options)
The policy uses the first fetch of worker info list as the base, and visits each of them in a
round-robin manner in the subsequent calls.
|
Optional<WorkerNetAddress> |
LocalFirstAvoidEvictionPolicy.getWorker(GetWorkerOptions options) |
Optional<WorkerNetAddress> |
DeterministicHashPolicy.getWorker(GetWorkerOptions options) |
Optional<WorkerNetAddress> |
CapacityBaseRandomPolicy.getWorker(GetWorkerOptions options) |
Optional<WorkerNetAddress> |
LocalFirstPolicy.getWorker(GetWorkerOptions options) |
Optional<WorkerNetAddress> |
MostAvailableFirstPolicy.getWorker(GetWorkerOptions options)
The policy returns null if no worker is qualified.
|
Optional<WorkerNetAddress> |
SpecificHostPolicy.getWorker(GetWorkerOptions options)
Returns null if no active worker matches the hostname
provided in WORKER_HOSTNAME (alluxio.worker.hostname).
|
Optional<WorkerNetAddress> |
BlockLocationPolicy.getWorker(GetWorkerOptions options)
Gets the worker's network address for serving operations requested for the block.
|
Modifier and Type | Method and Description |
---|---|
static GetWorkerOptions |
GetWorkerOptions.defaults() |
GetWorkerOptions |
GetWorkerOptions.setBlockInfo(BlockInfo blockInfo) |
GetWorkerOptions |
GetWorkerOptions.setBlockWorkerInfos(List<BlockWorkerInfo> blockWorkerInfos) |
Modifier and Type | Method and Description |
---|---|
Optional<WorkerNetAddress> |
ClientIOWritePolicy.getWorker(GetWorkerOptions options) |
Copyright © 2023. All Rights Reserved.