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.load
alluxio.job.plan.meta
alluxio.job.plan.migrate
alluxio.job.plan.persist
alluxio.job.plan.replicate
alluxio.job.plan.stress
alluxio.job.plan.transform
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.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>	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.load

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

Modifier and Type	Method and Description
Set<Pair<WorkerInfo,ArrayList<LoadDefinition.LoadTask>>>	LoadDefinition.selectExecutors(LoadConfig config, List<WorkerInfo> jobWorkerInfoList, SelectExecutorsContext context)

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

Modifier and Type	Method and Description
Set<Pair<WorkerInfo,ArrayList<LoadDefinition.LoadTask>>>	LoadDefinition.selectExecutors(LoadConfig 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)
Set<Pair<WorkerInfo,SetReplicaTask>>	SetReplicaDefinition.selectExecutors(SetReplicaConfig 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)
Set<Pair<WorkerInfo,SetReplicaTask>>	SetReplicaDefinition.selectExecutors(SetReplicaConfig 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.job.plan.transform

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

Modifier and Type	Method and Description
Set<Pair<WorkerInfo,ArrayList<CompactTask>>>	CompactDefinition.selectExecutors(CompactConfig config, List<WorkerInfo> jobWorkers, SelectExecutorsContext context)

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

Modifier and Type	Method and Description
Set<Pair<WorkerInfo,ArrayList<CompactTask>>>	CompactDefinition.selectExecutors(CompactConfig config, List<WorkerInfo> jobWorkers, 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>	BlockMaster.getLostWorkersInfoList()
List<WorkerInfo>	DefaultBlockMaster.getLostWorkersInfoList()
List<WorkerInfo>	BlockMaster.getWorkerInfoList()
List<WorkerInfo>	DefaultBlockMaster.getWorkerInfoList()
List<WorkerInfo>	BlockMaster.getWorkerReport(GetWorkerReportOptions options) Gets the worker information list for report CLI.
List<WorkerInfo>	DefaultBlockMaster.getWorkerReport(GetWorkerReportOptions options)

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, boolean isLiveWorker) 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.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 types with arguments of type WorkerInfo

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

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

Modifier and Type	Method and Description
Optional<LoadJob.LoadTask>	LoadJob.getNextTask(WorkerInfo worker) get next load task.

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

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

Modifier and Type	Method and Description
Map<WorkerInfo,CloseableResource<BlockWorkerClient>>	Scheduler.getActiveWorkers() Get active workers.
List<WorkerInfo>	DefaultWorkerProvider.getWorkerInfos()

Uses of WorkerInfo in alluxio.scheduler.job

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

Modifier and Type	Method and Description
List<WorkerInfo>	WorkerProvider.getWorkerInfos() Gets a list of worker information.

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

Modifier and Type	Method and Description
Optional<T>	Job.getNextTask(WorkerInfo worker)

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>	AlluxioMasterInfo.getWorkers()
List<WorkerInfo>	AlluxioJobMasterInfo.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)
AlluxioMasterInfo	AlluxioMasterInfo.setWorkers(List<WorkerInfo> workers)
AlluxioJobMasterInfo	AlluxioJobMasterInfo.setWorkers(List<WorkerInfo> workers)