Package | Description |
---|---|
alluxio.client.block | |
alluxio.client.block.policy | |
alluxio.client.file | |
alluxio.client.file.options | |
alluxio.stress.cli.client |
Modifier and Type | Method and Description |
---|---|
Pair<WorkerNetAddress,BlockInStream.BlockInStreamSource> |
BlockStoreClient.getDataSourceAndType(BlockInfo info,
URIStatus status,
BlockLocationPolicy policy,
Map<WorkerNetAddress,Long> failedWorkers)
Gets the data source and type of data source of a block.
|
Modifier and Type | Class and Description |
---|---|
class |
CapacityBasedDeterministicHashPolicy
A policy that pseudo-randomly distributes blocks between workers according to their capacity,
so that the probability a worker is chosen is equal to the ratio of its capacity over total
capacity of all workers, provided that the blocks requested follow a uniform distribution.
|
class |
CapacityBaseRandomPolicy
Randomly distribute workload based on the worker capacities so bigger workers get more requests.
|
class |
DeterministicHashPolicy
This policy maps the blockId to several deterministic Alluxio workers.
|
class |
LocalFirstAvoidEvictionPolicy
A policy that returns the local worker first, and if the local worker doesn't
exist or doesn't have enough availability, will select the nearest worker from the active
workers list with sufficient availability.
|
class |
LocalFirstPolicy
A policy that returns the local worker first, and if the local worker doesn't
exist or doesn't have enough capacity, will select the nearest worker from the active
workers list with sufficient capacity.
|
class |
MostAvailableFirstPolicy
A policy that returns the worker with the most available bytes.
|
class |
RoundRobinPolicy
A policy that chooses the worker for the next block in a round-robin manner and skips workers
that do not have enough space.
|
class |
SpecificHostPolicy
Always returns a worker with the hostname specified by
PropertyKey.WORKER_HOSTNAME (alluxio.worker.hostname). |
Modifier and Type | Method and Description |
---|---|
static BlockLocationPolicy |
BlockLocationPolicy.Factory.create(Class<?> blockLocationPolicyClass,
AlluxioConfiguration conf)
Factory for creating
BlockLocationPolicy . |
Modifier and Type | Method and Description |
---|---|
BlockLocationPolicy |
FileSystemContext.getReadBlockLocationPolicy(AlluxioConfiguration alluxioConf)
Gets the readBlockLocationPolicy.
|
BlockLocationPolicy |
FileSystemContext.getWriteBlockLocationPolicy(AlluxioConfiguration alluxioConf)
Gets the writeBlockLocationPolicy.
|
Modifier and Type | Method and Description |
---|---|
BlockLocationPolicy |
OutStreamOptions.getLocationPolicy() |
BlockLocationPolicy |
InStreamOptions.getUfsReadLocationPolicy() |
Modifier and Type | Method and Description |
---|---|
OutStreamOptions |
OutStreamOptions.setLocationPolicy(BlockLocationPolicy locationPolicy) |
void |
InStreamOptions.setUfsReadLocationPolicy(BlockLocationPolicy ufsReadLocationPolicy)
Sets block read location policy.
|
Modifier and Type | Class and Description |
---|---|
class |
ClientIOWritePolicy
Write type for restricting the writes to a set number of workers.
|
Copyright © 2023. All Rights Reserved.