public final class SchedulerDriver extends Object
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.
|
Modifier and Type | Field and Description |
---|---|
static ObjectSerializableCodec<String> |
CODEC |
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.
|
public static final ObjectSerializableCodec<String> CODEC
public int clearList()
public String getTaskStatus(int taskId) throws NotFoundException
NotFoundException
public int cancelTask(int taskId) throws NotFoundException, UnsuccessfulException
public int submitCommand(String command)
public int setMaxEvaluators(int targetNum) throws UnsuccessfulException
UnsuccessfulException
Copyright © 2017 The Apache Software Foundation. All rights reserved.