org.apache.reef.examples.scheduler.driver

Class SchedulerDriver

java.lang.Object

org.apache.reef.examples.scheduler.driver.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.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	SchedulerDriver.ActiveContextHandler Now it is ready to schedule tasks.
class	SchedulerDriver.CompletedTaskHandler When a Task completes, the task is marked as finished.
class	SchedulerDriver.EvaluatorAllocatedHandler Evaluator is allocated.
class	SchedulerDriver.StartHandler The driver is ready to run.

Field Summary

Fields

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

Method Summary

Methods

Modifier and Type	Method and Description
int	cancelTask(int taskId) Cancel a Task waiting on the queue.
int	clearList() Clear all the Tasks from the waiting queue.
Map<String,List<Integer>>	getList() Get the list of tasks in the scheduler.
String	getTaskStatus(int taskId) Get the status of a task.
int	setMaxEvaluators(int targetNum) Update the maximum number of evaluators to hold.
int	submitCommand(String command) 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

Method Detail

getList

public Map<String,List<Integer>> getList()

Get the list of tasks in the scheduler.

clearList

public int clearList()

Clear all the Tasks from the waiting queue.

getTaskStatus

public String getTaskStatus(int taskId)
                     throws NotFoundException

Get the status of a task.

Throws:

NotFoundException

cancelTask

public int cancelTask(int taskId)
               throws NotFoundException,
                      UnsuccessfulException

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

Throws:

NotFoundException

UnsuccessfulException

submitCommand

public int submitCommand(String command)

Submit a command to schedule.

setMaxEvaluators

public int setMaxEvaluators(int targetNum)
                     throws UnsuccessfulException

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.

Throws:

UnsuccessfulException