Modifier and Type | Method and Description |
---|---|
List<WorkerInfo> |
RetryHandlingBlockMasterClient.getWorkerInfoList() |
List<WorkerInfo> |
BlockMasterClient.getWorkerInfoList()
Gets the worker information of live workers(support older version Alluxio server).
|
List<WorkerInfo> |
RetryHandlingBlockMasterClient.getWorkerReport(GetWorkerReportOptions options) |
List<WorkerInfo> |
BlockMasterClient.getWorkerReport(GetWorkerReportOptions options)
Gets the worker information of selected workers and selected fields for report CLI.
|
Modifier and Type | Method and Description |
---|---|
static WorkerInfo |
GrpcUtils.fromProto(WorkerInfo workerInfo)
Converts a proto type to a wire type.
|
Modifier and Type | Method and Description |
---|---|
static WorkerInfo |
GrpcUtils.toProto(WorkerInfo workerInfo)
Converts wire type to proto type.
|
Modifier and Type | Method and Description |
---|---|
Map<WorkerInfo,P> |
JobDefinition.selectExecutors(T config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext selectExecutorsContext)
Selects the workers to run the task.
|
Modifier and Type | Method and Description |
---|---|
String |
JobDefinition.join(T config,
Map<WorkerInfo,R> taskResults)
Joins the task results on the master.
|
String |
AbstractVoidJobDefinition.join(T config,
Map<WorkerInfo,SerializableVoid> taskResults) |
Map<WorkerInfo,P> |
JobDefinition.selectExecutors(T config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext selectExecutorsContext)
Selects the workers to run the task.
|
Modifier and Type | Method and Description |
---|---|
Map<WorkerInfo,ArrayList<CompositeTask>> |
CompositeDefinition.selectExecutors(CompositeConfig config,
List<WorkerInfo> jobWorkers,
SelectExecutorsContext context) |
Modifier and Type | Method and Description |
---|---|
Map<WorkerInfo,ArrayList<CompositeTask>> |
CompositeDefinition.selectExecutors(CompositeConfig config,
List<WorkerInfo> jobWorkers,
SelectExecutorsContext context) |
Modifier and Type | Method and Description |
---|---|
Map<WorkerInfo,ArrayList<LoadDefinition.LoadTask>> |
LoadDefinition.selectExecutors(LoadConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context) |
Modifier and Type | Method and Description |
---|---|
Map<WorkerInfo,ArrayList<LoadDefinition.LoadTask>> |
LoadDefinition.selectExecutors(LoadConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context) |
Modifier and Type | Method and Description |
---|---|
WorkerInfo |
MasterWorkerInfo.generateClientWorkerInfo() |
Modifier and Type | Method and Description |
---|---|
Map<WorkerInfo,ArrayList<MigrateCommand>> |
MigrateDefinition.selectExecutors(MigrateConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context)
Selects the workers to run the task.
|
Modifier and Type | Method and Description |
---|---|
Map<WorkerInfo,ArrayList<MigrateCommand>> |
MigrateDefinition.selectExecutors(MigrateConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context)
Selects the workers to run the task.
|
Modifier and Type | Method and Description |
---|---|
Map<WorkerInfo,SerializableVoid> |
PersistDefinition.selectExecutors(PersistConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context) |
Modifier and Type | Method and Description |
---|---|
Map<WorkerInfo,SerializableVoid> |
PersistDefinition.selectExecutors(PersistConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context) |
Modifier and Type | Method and Description |
---|---|
Map<WorkerInfo,SerializableVoid> |
EvictDefinition.selectExecutors(EvictConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context) |
Map<WorkerInfo,SerializableVoid> |
MoveDefinition.selectExecutors(MoveConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context) |
Map<WorkerInfo,SerializableVoid> |
ReplicateDefinition.selectExecutors(ReplicateConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context) |
Modifier and Type | Method and Description |
---|---|
Map<WorkerInfo,SerializableVoid> |
EvictDefinition.selectExecutors(EvictConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context) |
Map<WorkerInfo,SerializableVoid> |
MoveDefinition.selectExecutors(MoveConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context) |
Map<WorkerInfo,SerializableVoid> |
ReplicateDefinition.selectExecutors(ReplicateConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context) |
Modifier and Type | Method and Description |
---|---|
Map<WorkerInfo,ArrayList<CompactTask>> |
CompactDefinition.selectExecutors(CompactConfig config,
List<WorkerInfo> jobWorkers,
SelectExecutorsContext context) |
Modifier and Type | Method and Description |
---|---|
Map<WorkerInfo,ArrayList<CompactTask>> |
CompactDefinition.selectExecutors(CompactConfig config,
List<WorkerInfo> jobWorkers,
SelectExecutorsContext context) |
Modifier and Type | Method and Description |
---|---|
List<WorkerInfo> |
DefaultBlockMaster.getLostWorkersInfoList() |
List<WorkerInfo> |
BlockMaster.getLostWorkersInfoList() |
List<WorkerInfo> |
DefaultBlockMaster.getWorkerInfoList() |
List<WorkerInfo> |
BlockMaster.getWorkerInfoList() |
List<WorkerInfo> |
DefaultBlockMaster.getWorkerReport(GetWorkerReportOptions options) |
List<WorkerInfo> |
BlockMaster.getWorkerReport(GetWorkerReportOptions options)
Gets the worker information list for report CLI.
|
Modifier and Type | Method and Description |
---|---|
WorkerInfo |
MasterWorkerInfo.generateWorkerInfo(Set<GetWorkerReportOptions.WorkerInfoField> fieldRange,
boolean isLiveWorker)
Gets the selected field information for this worker.
|
Modifier and Type | Method and Description |
---|---|
List<WorkerInfo> |
FileSystemMaster.getWorkerInfoList() |
List<WorkerInfo> |
DefaultFileSystemMaster.getWorkerInfoList() |
Modifier and Type | Method and Description |
---|---|
List<WorkerInfo> |
FileSystemMasterView.getWorkerInfoList() |
Modifier and Type | Method and Description |
---|---|
List<WorkerInfo> |
JobMaster.getWorkerInfoList() |
Modifier and Type | Method and Description |
---|---|
long |
JobTracker.addJob(JobConfig jobConfig,
CommandManager manager,
JobServerContext ctx,
List<WorkerInfo> workers)
Adds a job with the given
JobConfig to the job tracker. |
static JobCoordinator |
JobCoordinator.create(CommandManager commandManager,
JobServerContext jobServerContext,
List<WorkerInfo> workerInfoList,
Long jobId,
JobConfig jobConfig,
java.util.function.Consumer<JobInfo> statusChangeCallback)
Creates a new instance of the
JobCoordinator . |
Modifier and Type | Method and Description |
---|---|
static NodeInfo[] |
WebUtils.generateOrderedNodeInfos(Collection<WorkerInfo> workerInfos)
Order the nodes by hostName and generate
NodeInfo list for UI display. |
Constructor and Description |
---|
NodeInfo(WorkerInfo workerInfo)
Instantiates a new Node info.
|
Modifier and Type | Method and Description |
---|---|
WorkerInfo |
WorkerInfo.setAddress(WorkerNetAddress address) |
WorkerInfo |
WorkerInfo.setCapacityBytes(long capacityBytes) |
WorkerInfo |
WorkerInfo.setCapacityBytesOnTiers(Map<String,Long> capacityBytesOnTiers) |
WorkerInfo |
WorkerInfo.setId(long id) |
WorkerInfo |
WorkerInfo.setLastContactSec(int lastContactSec) |
WorkerInfo |
WorkerInfo.setStartTimeMs(long startTimeMs) |
WorkerInfo |
WorkerInfo.setState(String state) |
WorkerInfo |
WorkerInfo.setUsedBytes(long usedBytes) |
WorkerInfo |
WorkerInfo.setUsedBytesOnTiers(Map<String,Long> usedBytesOnTiers) |
Modifier and Type | Method and Description |
---|---|
List<WorkerInfo> |
AlluxioMasterInfo.getLostWorkers() |
List<WorkerInfo> |
AlluxioMasterInfo.getWorkers() |
List<WorkerInfo> |
AlluxioJobMasterInfo.getWorkers() |
Modifier and Type | Method and Description |
---|---|
int |
WorkerInfo.LastContactSecComparator.compare(WorkerInfo o1,
WorkerInfo o2) |
Modifier and Type | Method and Description |
---|---|
AlluxioMasterInfo |
AlluxioMasterInfo.setLostWorkers(List<WorkerInfo> lostWorkers) |
AlluxioMasterInfo |
AlluxioMasterInfo.setWorkers(List<WorkerInfo> workers) |
AlluxioJobMasterInfo |
AlluxioJobMasterInfo.setWorkers(List<WorkerInfo> workers) |
Copyright © 2023. All Rights Reserved.