Package | Description |
---|---|
alluxio.client.block | |
alluxio.client.block.policy | |
alluxio.client.file.options | |
alluxio.stress.cli.client |
Modifier and Type | Method and Description |
---|---|
Pair<WorkerNetAddress,BlockInStream.BlockInStreamSource> |
AlluxioBlockStore.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 |
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 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 have enough availability, will select the nearest worker from the active
workers list with sufficient availability.
|
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(String blockLocationPolicyClass,
AlluxioConfiguration conf)
Factory for creating
BlockLocationPolicy . |
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
A write type for restricting the writes to a set number of workers.
|
Copyright © 2023. All Rights Reserved.