Package | Description |
---|---|
alluxio.cli.fsadmin.command | |
alluxio.client.file | |
alluxio.client.file.dora | |
alluxio.job.util |
Modifier and Type | Method and Description |
---|---|
static String |
WorkerAddressUtils.workerListToString(Set<BlockWorkerInfo> worker)
Converts a set of worker metadata to string.
|
Modifier and Type | Method and Description |
---|---|
List<BlockWorkerInfo> |
FileSystemContext.getAllWorkers()
Gets the worker information list.
|
List<BlockWorkerInfo> |
FileSystemContext.getCachedWorkers()
Gets the cached live worker information list.
|
List<BlockWorkerInfo> |
FileSystemContext.getCachedWorkers(FileSystemContext.GetWorkerListType type)
Gets the cached worker information list.
|
List<BlockWorkerInfo> |
FileSystemContext.getLiveWorkers()
Gets the live worker information list.
|
List<BlockWorkerInfo> |
FileSystemContext.getLostWorkers()
Gets the lost worker information list.
|
Modifier and Type | Method and Description |
---|---|
protected BlockWorkerInfo |
DoraCacheClient.choosePreferredWorker(List<BlockWorkerInfo> workers)
Chooses a client preferred worker from multiple workers which hold multiple replicas.
|
Modifier and Type | Method and Description |
---|---|
List<BlockWorkerInfo> |
ConsistentHashProvider.getMultiple(String key,
int count)
Finds multiple workers from the hash ring.
|
List<BlockWorkerInfo> |
LocalWorkerPolicy.getPreferredWorkers(List<BlockWorkerInfo> blockWorkerInfos,
String fileId,
int count)
Finds a local worker from the available workers, matching by hostname.
|
List<BlockWorkerInfo> |
ConsistentHashPolicy.getPreferredWorkers(List<BlockWorkerInfo> blockWorkerInfos,
String fileId,
int count) |
List<BlockWorkerInfo> |
WorkerLocationPolicy.getPreferredWorkers(List<BlockWorkerInfo> blockWorkerInfos,
String fileId,
int count)
Find a specified number of workers following the logic defined by the policy.
|
Modifier and Type | Method and Description |
---|---|
protected BlockWorkerInfo |
DoraCacheClient.choosePreferredWorker(List<BlockWorkerInfo> workers)
Chooses a client preferred worker from multiple workers which hold multiple replicas.
|
List<BlockWorkerInfo> |
LocalWorkerPolicy.getPreferredWorkers(List<BlockWorkerInfo> blockWorkerInfos,
String fileId,
int count)
Finds a local worker from the available workers, matching by hostname.
|
List<BlockWorkerInfo> |
ConsistentHashPolicy.getPreferredWorkers(List<BlockWorkerInfo> blockWorkerInfos,
String fileId,
int count) |
List<BlockWorkerInfo> |
WorkerLocationPolicy.getPreferredWorkers(List<BlockWorkerInfo> blockWorkerInfos,
String fileId,
int count)
Find a specified number of workers following the logic defined by the policy.
|
void |
ConsistentHashProvider.refresh(List<BlockWorkerInfo> workerInfos,
int numVirtualNodes)
Initializes or refreshes the worker list using the given list of workers and number of
virtual nodes.
|
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.