org.apache.reef.examples.scheduler

Class SchedulerDriver

java.lang.Object

org.apache.reef.examples.scheduler.SchedulerDriver

public final class SchedulerDriver
extends Object

Driver for TaskScheduler. It receives the commands by HttpRequest and execute them in a FIFO(First In First Out) order.

Field Summary

Fields

Modifier and Type	Field and Description
static ObjectSerializableCodec<String>	CODEC

Constructor Summary

Constructors

Constructor and Description
SchedulerDriver(EvaluatorRequestor requestor, boolean retainable, org.apache.reef.examples.scheduler.Scheduler scheduler)

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.reef.examples.scheduler.SchedulerResponse	cancelTask(List<String> args) Cancel a Task waiting on the queue.
org.apache.reef.examples.scheduler.SchedulerResponse	clearList() Clear all the Tasks from the waiting queue.
org.apache.reef.examples.scheduler.SchedulerResponse	getList() Get the list of tasks in the scheduler.
org.apache.reef.examples.scheduler.SchedulerResponse	getTaskStatus(List<String> args) Get the status of a task.
org.apache.reef.examples.scheduler.SchedulerResponse	setMaxEvaluators(List<String> args) Update the maximum number of evaluators to hold.
org.apache.reef.examples.scheduler.SchedulerResponse	submitCommands(List<String> args) Submit a command to schedule.

Methods inherited from class java.lang.Object

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

Field Detail

CODEC

public static final ObjectSerializableCodec<String> CODEC

Constructor Detail

SchedulerDriver

@Inject
public SchedulerDriver(EvaluatorRequestor requestor,
                      boolean retainable,
                      org.apache.reef.examples.scheduler.Scheduler scheduler)

Method Detail

getList

public org.apache.reef.examples.scheduler.SchedulerResponse getList()

Get the list of tasks in the scheduler.

clearList

public org.apache.reef.examples.scheduler.SchedulerResponse clearList()

Clear all the Tasks from the waiting queue.

getTaskStatus

public org.apache.reef.examples.scheduler.SchedulerResponse getTaskStatus(List<String> args)

Get the status of a task.

cancelTask

public org.apache.reef.examples.scheduler.SchedulerResponse cancelTask(List<String> args)

Cancel a Task waiting on the queue. A task cannot be canceled once it is running.

submitCommands

public org.apache.reef.examples.scheduler.SchedulerResponse submitCommands(List<String> args)

Submit a command to schedule.

setMaxEvaluators

public org.apache.reef.examples.scheduler.SchedulerResponse setMaxEvaluators(List<String> args)

Update the maximum number of evaluators to hold. Request more evaluators in case there are pending tasks in the queue and the number of evaluators is less than the limit.