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 |
---|---|
WorkerInfo |
MasterWorkerInfo.generateClientWorkerInfo() |
Modifier and Type | Method and Description |
---|---|
Set<Pair<WorkerInfo,SerializableVoid>> |
NoopPlanDefinition.selectExecutors(NoopPlanConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext selectExecutorsContext) |
Set<Pair<WorkerInfo,P>> |
PlanDefinition.selectExecutors(T config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext selectExecutorsContext)
Selects the workers to run the task.
|
Modifier and Type | Method and Description |
---|---|
String |
PlanDefinition.join(T config,
Map<WorkerInfo,R> taskResults)
Joins the task results on the master.
|
String |
AbstractVoidPlanDefinition.join(T config,
Map<WorkerInfo,SerializableVoid> taskResults) |
Set<Pair<WorkerInfo,SerializableVoid>> |
NoopPlanDefinition.selectExecutors(NoopPlanConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext selectExecutorsContext) |
Set<Pair<WorkerInfo,P>> |
PlanDefinition.selectExecutors(T config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext selectExecutorsContext)
Selects the workers to run the task.
|
Modifier and Type | Method and Description |
---|---|
Set<Pair<WorkerInfo,BatchedJobDefinition.BatchedJobTask>> |
BatchedJobDefinition.selectExecutors(BatchedJobConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context) |
Modifier and Type | Method and Description |
---|---|
Set<Pair<WorkerInfo,BatchedJobDefinition.BatchedJobTask>> |
BatchedJobDefinition.selectExecutors(BatchedJobConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context) |
Modifier and Type | Method and Description |
---|---|
Set<Pair<WorkerInfo,ArrayList<LoadDefinition.LoadTask>>> |
LoadDefinition.selectExecutors(LoadConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context) |
Modifier and Type | Method and Description |
---|---|
Set<Pair<WorkerInfo,ArrayList<LoadDefinition.LoadTask>>> |
LoadDefinition.selectExecutors(LoadConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context) |
Modifier and Type | Method and Description |
---|---|
void |
PlanInfo.addTask(long taskId,
WorkerInfo workerInfo,
Object args)
Registers a task.
|
Modifier and Type | Method and Description |
---|---|
Set<Pair<WorkerInfo,MigrateCommand>> |
MigrateDefinition.selectExecutors(MigrateConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context)
Selects the workers to run the task.
|
Modifier and Type | Method and Description |
---|---|
Set<Pair<WorkerInfo,MigrateCommand>> |
MigrateDefinition.selectExecutors(MigrateConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context)
Selects the workers to run the task.
|
Modifier and Type | Method and Description |
---|---|
Set<Pair<WorkerInfo,SerializableVoid>> |
PersistDefinition.selectExecutors(PersistConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context) |
Modifier and Type | Method and Description |
---|---|
Set<Pair<WorkerInfo,SerializableVoid>> |
PersistDefinition.selectExecutors(PersistConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context) |
Modifier and Type | Method and Description |
---|---|
Set<Pair<WorkerInfo,SerializableVoid>> |
MoveDefinition.selectExecutors(MoveConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context) |
Set<Pair<WorkerInfo,SetReplicaTask>> |
SetReplicaDefinition.selectExecutors(SetReplicaConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context) |
Modifier and Type | Method and Description |
---|---|
Set<Pair<WorkerInfo,SerializableVoid>> |
MoveDefinition.selectExecutors(MoveConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context) |
Set<Pair<WorkerInfo,SetReplicaTask>> |
SetReplicaDefinition.selectExecutors(SetReplicaConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context) |
Modifier and Type | Method and Description |
---|---|
Set<Pair<WorkerInfo,ArrayList<String>>> |
StressBenchDefinition.selectExecutors(StressBenchConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context) |
Modifier and Type | Method and Description |
---|---|
String |
StressBenchDefinition.join(StressBenchConfig config,
Map<WorkerInfo,String> taskResults) |
Set<Pair<WorkerInfo,ArrayList<String>>> |
StressBenchDefinition.selectExecutors(StressBenchConfig config,
List<WorkerInfo> jobWorkerInfoList,
SelectExecutorsContext context) |
Modifier and Type | Method and Description |
---|---|
Set<Pair<WorkerInfo,ArrayList<CompactTask>>> |
CompactDefinition.selectExecutors(CompactConfig config,
List<WorkerInfo> jobWorkers,
SelectExecutorsContext context) |
Modifier and Type | Method and Description |
---|---|
Set<Pair<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> |
DefaultFileSystemMaster.getWorkerInfoList() |
List<WorkerInfo> |
FileSystemMaster.getWorkerInfoList() |
Modifier and Type | Method and Description |
---|---|
Map<WorkerInfo,CloseableResource<BlockWorkerClient>> |
LoadManager.getActiveWorkers()
Get active workers.
|
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 |
---|---|
static PlanCoordinator |
PlanCoordinator.create(CommandManager commandManager,
JobServerContext jobServerContext,
List<WorkerInfo> workerInfoList,
Long jobId,
JobConfig jobConfig,
java.util.function.Consumer<PlanInfo> statusChangeCallback)
Creates a new instance of the
PlanCoordinator . |
void |
PlanTracker.run(PlanConfig jobConfig,
CommandManager manager,
JobServerContext ctx,
List<WorkerInfo> workers,
long jobId)
Adds a job with the given
JobConfig to the job tracker. |
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.setBlockCount(long blockCount) |
WorkerInfo |
WorkerInfo.setCapacityBytes(long capacityBytes) |
WorkerInfo |
WorkerInfo.setCapacityBytesOnTiers(Map<String,Long> capacityBytesOnTiers) |
WorkerInfo |
WorkerInfo.setId(long id) |
WorkerInfo |
WorkerInfo.setLastContactSec(int lastContactSec) |
WorkerInfo |
WorkerInfo.setRevision(String revision) |
WorkerInfo |
WorkerInfo.setStartTimeMs(long startTimeMs) |
WorkerInfo |
WorkerInfo.setState(String state) |
WorkerInfo |
WorkerInfo.setUsedBytes(long usedBytes) |
WorkerInfo |
WorkerInfo.setUsedBytesOnTiers(Map<String,Long> usedBytesOnTiers) |
WorkerInfo |
WorkerInfo.setVersion(String version) |
Modifier and Type | Method and Description |
---|---|
List<WorkerInfo> |
AlluxioMasterInfo.getLostWorkers() |
List<WorkerInfo> |
AlluxioJobMasterInfo.getWorkers() |
List<WorkerInfo> |
AlluxioMasterInfo.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) |
AlluxioJobMasterInfo |
AlluxioJobMasterInfo.setWorkers(List<WorkerInfo> workers) |
AlluxioMasterInfo |
AlluxioMasterInfo.setWorkers(List<WorkerInfo> workers) |
Copyright © 2023. All Rights Reserved.