alluxio.master.scheduler

Class Scheduler.WorkerInfoHub

java.lang.Object

alluxio.master.scheduler.Scheduler.WorkerInfoHub

Enclosing class:

Scheduler

public class Scheduler.WorkerInfoHub
extends Object

Worker information hub.

Field Summary

Fields

Modifier and Type	Field and Description
Map<Scheduler.WorkerInfoIdentity,CloseableResource<BlockWorkerClient>>	mActiveWorkers

Constructor Summary

Constructors

Constructor and Description
WorkerInfoHub(Scheduler scheduler, WorkerProvider workerProvider) Constructor.

Method Summary

Modifier and Type	Method and Description
boolean	enqueueTaskForWorker(WorkerInfo workerInfo, Task task) Enqueue task for worker.
Map<Scheduler.WorkerInfoIdentity,Scheduler.BoundedPriorityBlockingQueue<Task>>	getWorkerToTaskQ()
void	kickStartTasks() Kick stark tasks for each worker task q.
void	updateWorkers() Refresh active workers.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

mActiveWorkers

public Map<Scheduler.WorkerInfoIdentity,CloseableResource<BlockWorkerClient>> mActiveWorkers

Constructor Detail

WorkerInfoHub

public WorkerInfoHub(Scheduler scheduler,
                     WorkerProvider workerProvider)

Constructor.

Parameters:

scheduler - scheduler

workerProvider - worker provider

Method Detail

kickStartTasks

public void kickStartTasks()

Kick stark tasks for each worker task q.

enqueueTaskForWorker

public boolean enqueueTaskForWorker(@Nullable
                                    WorkerInfo workerInfo,
                                    Task task)

Enqueue task for worker.

Parameters:

workerInfo - the worker

task - the task

Returns:

whether the task is enqueued successfully

getWorkerToTaskQ

public Map<Scheduler.WorkerInfoIdentity,Scheduler.BoundedPriorityBlockingQueue<Task>> getWorkerToTaskQ()

Returns:

the worker to task queue

updateWorkers

public void updateWorkers()

Refresh active workers.