alluxio.master.job.command

Class CommandManager

java.lang.Object

alluxio.master.job.command.CommandManager

@ThreadSafe
public final class CommandManager
extends Object

A command manager that manages the commands to issue to the workers.

Constructor Summary

Constructors

Constructor and Description
CommandManager() Constructs a new CommandManager.

Method Summary

Modifier and Type	Method and Description
List<JobCommand>	pollAllPendingCommands(long workerId) Polls all the pending commands to a worker and removes the commands from the queue.
void	submitCancelTaskCommand(long jobId, int taskId, long workerId) Submits a cancel-task command to a specified worker.
void	submitRunTaskCommand(long jobId, int taskId, JobConfig jobConfig, Object taskArgs, long workerId) Submits a run-task command to a specified worker.

Methods inherited from class java.lang.Object

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

Constructor Detail

CommandManager

public CommandManager()

Constructs a new CommandManager.

Method Detail

submitRunTaskCommand

public void submitRunTaskCommand(long jobId,
                                 int taskId,
                                 JobConfig jobConfig,
                                 Object taskArgs,
                                 long workerId)

Submits a run-task command to a specified worker.

Parameters:

jobId - the id of the job

taskId - the id of the task

jobConfig - the job configuration

taskArgs - the arguments passed to the executor on the worker

workerId - the id of the worker

submitCancelTaskCommand

public void submitCancelTaskCommand(long jobId,
                                    int taskId,
                                    long workerId)

Submits a cancel-task command to a specified worker.

Parameters:

jobId - the job id

taskId - the task id

workerId - the worker id

pollAllPendingCommands

public List<JobCommand> pollAllPendingCommands(long workerId)

Polls all the pending commands to a worker and removes the commands from the queue.

Parameters:

workerId - id of the worker to send the commands to

Returns:

the list of the commends polled