Uses of Class
alluxio.wire.WorkerInfo

Packages that use WorkerInfo

Package	Description
alluxio.client.block
alluxio.grpc
alluxio.job
alluxio.job.plan
alluxio.job.plan.batch
alluxio.job.plan.meta
alluxio.job.plan.migrate
alluxio.job.plan.persist
alluxio.job.plan.replicate
alluxio.job.plan.stress
alluxio.master.block
alluxio.master.block.meta
alluxio.master.file
alluxio.master.file.meta
alluxio.master.job
alluxio.master.job.plan
alluxio.master.scheduler
alluxio.membership
alluxio.scheduler.job
alluxio.util.webui
alluxio.wire

Uses of WorkerInfo in alluxio.client.block

Methods in alluxio.client.block that return types with arguments of type WorkerInfo

Modifier and Type	Method and Description
List<WorkerInfo>	RetryHandlingBlockMasterClient.getLostWorkerInfoList()
List<WorkerInfo>	BlockMasterClient.getLostWorkerInfoList() Gets the worker information of lost workers.
List<WorkerInfo>	AllMastersWorkerInfo.getPrimaryMasterWorkerInfo()
Map<Long,List<Pair<InetSocketAddress,WorkerInfo>>>	AllMastersWorkerInfo.getWorkerIdInfoMap()
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.

Constructor parameters in alluxio.client.block with type arguments of type WorkerInfo

Constructor and Description
AllMastersWorkerInfo(Map<Long,InetSocketAddress> workerIdAddressMap, List<InetSocketAddress> masterAddresses, InetSocketAddress primaryMasterAddress, List<WorkerInfo> primaryMasterWorkerInfo, Map<Long,List<Pair<InetSocketAddress,WorkerInfo>>> workerIdInfoMap)
AllMastersWorkerInfo(Map<Long,InetSocketAddress> workerIdAddressMap, List<InetSocketAddress> masterAddresses, InetSocketAddress primaryMasterAddress, List<WorkerInfo> primaryMasterWorkerInfo, Map<Long,List<Pair<InetSocketAddress,WorkerInfo>>> workerIdInfoMap)

Uses of WorkerInfo in alluxio.grpc

Methods in alluxio.grpc that return WorkerInfo

Modifier and Type	Method and Description
static WorkerInfo	GrpcUtils.fromProto(WorkerInfo workerInfo) Converts a proto type to a wire type.

Methods in alluxio.grpc with parameters of type WorkerInfo

Modifier and Type	Method and Description
static WorkerInfo	GrpcUtils.toProto(WorkerInfo workerInfo) Converts wire type to proto type.

Uses of WorkerInfo in alluxio.job

Methods in alluxio.job that return WorkerInfo

Modifier and Type	Method and Description
WorkerInfo	MasterWorkerInfo.generateClientWorkerInfo()

Uses of WorkerInfo in alluxio.job.plan

Methods in alluxio.job.plan that return types with arguments of type WorkerInfo

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.

Method parameters in alluxio.job.plan with type arguments of type WorkerInfo

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.

Uses of WorkerInfo in alluxio.job.plan.batch

Methods in alluxio.job.plan.batch that return types with arguments of type WorkerInfo

Modifier and Type	Method and Description
Set<Pair<WorkerInfo,BatchedJobDefinition.BatchedJobTask>>	BatchedJobDefinition.selectExecutors(BatchedJobConfig config, List<WorkerInfo> jobWorkerInfoList, SelectExecutorsContext context)

Method parameters in alluxio.job.plan.batch with type arguments of type WorkerInfo

Modifier and Type	Method and Description
Set<Pair<WorkerInfo,BatchedJobDefinition.BatchedJobTask>>	BatchedJobDefinition.selectExecutors(BatchedJobConfig config, List<WorkerInfo> jobWorkerInfoList, SelectExecutorsContext context)

Uses of WorkerInfo in alluxio.job.plan.meta

Methods in alluxio.job.plan.meta with parameters of type WorkerInfo

Modifier and Type	Method and Description
void	PlanInfo.addTask(long taskId, WorkerInfo workerInfo, Object args) Registers a task.

Uses of WorkerInfo in alluxio.job.plan.migrate

Methods in alluxio.job.plan.migrate that return types with arguments of type WorkerInfo

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.

Method parameters in alluxio.job.plan.migrate with type arguments of type WorkerInfo

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.

Uses of WorkerInfo in alluxio.job.plan.persist

Methods in alluxio.job.plan.persist that return types with arguments of type WorkerInfo

Modifier and Type	Method and Description
Set<Pair<WorkerInfo,SerializableVoid>>	PersistDefinition.selectExecutors(PersistConfig config, List<WorkerInfo> jobWorkerInfoList, SelectExecutorsContext context)

Method parameters in alluxio.job.plan.persist with type arguments of type WorkerInfo

Modifier and Type	Method and Description
Set<Pair<WorkerInfo,SerializableVoid>>	PersistDefinition.selectExecutors(PersistConfig config, List<WorkerInfo> jobWorkerInfoList, SelectExecutorsContext context)

Uses of WorkerInfo in alluxio.job.plan.replicate

Methods in alluxio.job.plan.replicate that return types with arguments of type WorkerInfo

Modifier and Type	Method and Description
Set<Pair<WorkerInfo,SerializableVoid>>	MoveDefinition.selectExecutors(MoveConfig config, List<WorkerInfo> jobWorkerInfoList, SelectExecutorsContext context)

Method parameters in alluxio.job.plan.replicate with type arguments of type WorkerInfo

Modifier and Type	Method and Description
Set<Pair<WorkerInfo,SerializableVoid>>	MoveDefinition.selectExecutors(MoveConfig config, List<WorkerInfo> jobWorkerInfoList, SelectExecutorsContext context)

Uses of WorkerInfo in alluxio.job.plan.stress

Methods in alluxio.job.plan.stress that return types with arguments of type WorkerInfo

Modifier and Type	Method and Description
Set<Pair<WorkerInfo,ArrayList<String>>>	StressBenchDefinition.selectExecutors(StressBenchConfig config, List<WorkerInfo> jobWorkerInfoList, SelectExecutorsContext context)

Method parameters in alluxio.job.plan.stress with type arguments of type WorkerInfo

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)

Uses of WorkerInfo in alluxio.master.block

Methods in alluxio.master.block that return types with arguments of type WorkerInfo

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.

Uses of WorkerInfo in alluxio.master.block.meta

Methods in alluxio.master.block.meta that return WorkerInfo

Modifier and Type	Method and Description
WorkerInfo	MasterWorkerInfo.generateWorkerInfo(Set<GetWorkerReportOptions.WorkerInfoField> fieldRange, WorkerState workerState) Gets the selected field information for this worker.

Uses of WorkerInfo in alluxio.master.file

Methods in alluxio.master.file that return types with arguments of type WorkerInfo

Modifier and Type	Method and Description
List<WorkerInfo>	DefaultFileSystemMaster.getLostWorkerList()
List<WorkerInfo>	FileSystemMaster.getLostWorkerList()
List<WorkerInfo>	DefaultFileSystemMaster.getWorkerInfoList()
List<WorkerInfo>	FileSystemMaster.getWorkerInfoList()

Uses of WorkerInfo in alluxio.master.file.meta

Methods in alluxio.master.file.meta that return types with arguments of type WorkerInfo

Modifier and Type	Method and Description
List<WorkerInfo>	FileSystemMasterView.getWorkerInfoList()

Uses of WorkerInfo in alluxio.master.job

Methods in alluxio.master.job that return WorkerInfo

Modifier and Type	Method and Description
protected WorkerInfo	HashBasedWorkerAssignPolicy.pickAWorker(String object, Collection<WorkerInfo> workerInfos)
protected WorkerInfo	RoundRobinWorkerAssignPolicy.pickAWorker(String object, Collection<WorkerInfo> workerInfos)
protected abstract WorkerInfo	WorkerAssignPolicy.pickAWorker(String object, Collection<WorkerInfo> workerInfos) Pick a worker based on the policy.

Methods in alluxio.master.job that return types with arguments of type WorkerInfo

Modifier and Type	Method and Description
List<WorkerInfo>	JobMaster.getWorkerInfoList()

Method parameters in alluxio.master.job with type arguments of type WorkerInfo

Modifier and Type	Method and Description
List<CopyJob.CopyTask>	CopyJob.getNextTasks(Collection<WorkerInfo> workers) get next load task.
List<LoadJob.LoadTask>	LoadJob.getNextTasks(Collection<WorkerInfo> workers) get next load task.
List<DoraLoadJob.DoraLoadTask>	DoraLoadJob.getNextTasks(Collection<WorkerInfo> workers)
List<MoveJob.MoveTask>	MoveJob.getNextTasks(Collection<WorkerInfo> workers) get next move task.
protected WorkerInfo	HashBasedWorkerAssignPolicy.pickAWorker(String object, Collection<WorkerInfo> workerInfos)
protected WorkerInfo	RoundRobinWorkerAssignPolicy.pickAWorker(String object, Collection<WorkerInfo> workerInfos)
protected abstract WorkerInfo	WorkerAssignPolicy.pickAWorker(String object, Collection<WorkerInfo> workerInfos) Pick a worker based on the policy.

Uses of WorkerInfo in alluxio.master.job.plan

Method parameters in alluxio.master.job.plan with type arguments of type WorkerInfo

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.

Uses of WorkerInfo in alluxio.master.scheduler

Fields in alluxio.master.scheduler declared as WorkerInfo

Modifier and Type	Field and Description
WorkerInfo	Scheduler.WorkerInfoIdentity.mWorkerInfo

Methods in alluxio.master.scheduler that return types with arguments of type WorkerInfo

Modifier and Type	Method and Description
Set<WorkerInfo>	Scheduler.getActiveWorkers() Get active workers.
List<WorkerInfo>	MembershipManagerWorkerProvider.getLiveWorkerInfos()
List<WorkerInfo>	DefaultWorkerProvider.getLiveWorkerInfos()
List<WorkerInfo>	WorkerProvider.getLiveWorkerInfos() Get live workerInfo list.
List<WorkerInfo>	MembershipManagerWorkerProvider.getWorkerInfos()
List<WorkerInfo>	DefaultWorkerProvider.getWorkerInfos()
List<WorkerInfo>	WorkerProvider.getWorkerInfos() Gets a list of worker information.

Methods in alluxio.master.scheduler with parameters of type WorkerInfo

Modifier and Type	Method and Description
boolean	Scheduler.WorkerInfoHub.enqueueTaskForWorker(WorkerInfo workerInfo, Task task) Enqueue task for worker.

Constructors in alluxio.master.scheduler with parameters of type WorkerInfo

Constructor and Description
WorkerInfoIdentity(WorkerInfo workerInfo) Constructor for WorkerInfoIdentity from WorkerInfo.

Uses of WorkerInfo in alluxio.membership

Methods in alluxio.membership that return types with arguments of type WorkerInfo

Modifier and Type	Method and Description
List<WorkerInfo>	StaticMembershipManager.getAllMembers()
List<WorkerInfo>	EtcdMembershipManager.getAllMembers()
List<WorkerInfo>	MembershipManager.getAllMembers() Get all registered worker members.
List<WorkerInfo>	MasterMembershipManager.getAllMembers()
List<WorkerInfo>	StaticMembershipManager.getFailedMembers()
List<WorkerInfo>	EtcdMembershipManager.getFailedMembers()
List<WorkerInfo>	MembershipManager.getFailedMembers() Get all failed workers.
List<WorkerInfo>	MasterMembershipManager.getFailedMembers()
List<WorkerInfo>	StaticMembershipManager.getLiveMembers()
List<WorkerInfo>	EtcdMembershipManager.getLiveMembers()
List<WorkerInfo>	MembershipManager.getLiveMembers() Get healthy workers.
List<WorkerInfo>	MasterMembershipManager.getLiveMembers()

Methods in alluxio.membership with parameters of type WorkerInfo

Modifier and Type	Method and Description
void	StaticMembershipManager.decommission(WorkerInfo worker)
void	EtcdMembershipManager.decommission(WorkerInfo worker)
void	MembershipManager.decommission(WorkerInfo worker) Decommision a worker.
void	MasterMembershipManager.decommission(WorkerInfo worker)
void	StaticMembershipManager.join(WorkerInfo worker)
void	EtcdMembershipManager.join(WorkerInfo workerInfo)
void	MembershipManager.join(WorkerInfo worker) An idempotent call to register to join the membership.
void	MasterMembershipManager.join(WorkerInfo worker)
void	StaticMembershipManager.stopHeartBeat(WorkerInfo worker)
void	EtcdMembershipManager.stopHeartBeat(WorkerInfo worker)
void	MembershipManager.stopHeartBeat(WorkerInfo worker) Stop heartbeating for liveness for current worker.
void	MasterMembershipManager.stopHeartBeat(WorkerInfo worker)

Uses of WorkerInfo in alluxio.scheduler.job

Methods in alluxio.scheduler.job that return WorkerInfo

Modifier and Type	Method and Description
WorkerInfo	Task.getMyRunningWorker() Get the worker info this task runs on.

Methods in alluxio.scheduler.job with parameters of type WorkerInfo

Modifier and Type	Method and Description
void	Task.execute(BlockWorkerClient client, WorkerInfo workerInfo) run the task and set the response future.
void	Task.setMyRunningWorker(WorkerInfo workerInfo) Set the worker info this task runs on.

Method parameters in alluxio.scheduler.job with type arguments of type WorkerInfo

Modifier and Type	Method and Description
List<T>	Job.getNextTasks(Collection<WorkerInfo> workers)

Uses of WorkerInfo in alluxio.util.webui

Method parameters in alluxio.util.webui with type arguments of type WorkerInfo

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.

Constructors in alluxio.util.webui with parameters of type WorkerInfo

Constructor and Description
NodeInfo(WorkerInfo workerInfo) Instantiates a new Node info.

Uses of WorkerInfo in alluxio.wire

Methods in alluxio.wire that return WorkerInfo

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)

Methods in alluxio.wire that return types with arguments of type WorkerInfo

Modifier and Type	Method and Description
List<WorkerInfo>	AlluxioMasterInfo.getLostWorkers()
List<WorkerInfo>	AlluxioJobMasterInfo.getWorkers()
List<WorkerInfo>	AlluxioMasterInfo.getWorkers()

Methods in alluxio.wire with parameters of type WorkerInfo

Modifier and Type	Method and Description
int	WorkerInfo.LastContactSecComparator.compare(WorkerInfo o1, WorkerInfo o2)

Method parameters in alluxio.wire with type arguments of type WorkerInfo

Modifier and Type	Method and Description
AlluxioMasterInfo	AlluxioMasterInfo.setLostWorkers(List<WorkerInfo> lostWorkers)
AlluxioJobMasterInfo	AlluxioJobMasterInfo.setWorkers(List<WorkerInfo> workers)
AlluxioMasterInfo	AlluxioMasterInfo.setWorkers(List<WorkerInfo> workers)