alluxio.worker.job.task

Class TaskExecutorManager

java.lang.Object

alluxio.worker.job.task.TaskExecutorManager

@ThreadSafe
public class TaskExecutorManager
extends Object

Manages the task executors.

Constructor Summary

Constructors

Constructor and Description
TaskExecutorManager(int taskExecutorPoolSize) Constructs a new instance of TaskExecutorManager.

Method Summary

Modifier and Type	Method and Description
void	cancelTask(long jobId, int taskId) Cancels the given task.
void	executeTask(long jobId, int taskId, JobConfig jobConfig, Serializable taskArgs, RunTaskContext context) Executes the given task.
List<TaskInfo>	getAndClearTaskUpdates()
void	notifyTaskCompletion(long jobId, int taskId, Object result) Notifies the completion of the task.
void	notifyTaskFailure(long jobId, int taskId, String errorMessage) Notifies the failure of the task.
void	restoreTaskUpdates(List<TaskInfo> tasks) Adds the given tasks to the task updates data structure.

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskExecutorManager

public TaskExecutorManager(int taskExecutorPoolSize)

Constructs a new instance of TaskExecutorManager.

Parameters:

taskExecutorPoolSize - number of task executors in the pool

Method Detail

notifyTaskCompletion

public void notifyTaskCompletion(long jobId,
                                 int taskId,
                                 Object result)

Notifies the completion of the task.

Parameters:

jobId - the job id

taskId - the task id

result - the task execution result

notifyTaskFailure

public void notifyTaskFailure(long jobId,
                              int taskId,
                              String errorMessage)

Notifies the failure of the task.

Parameters:

jobId - the job id

taskId - the task id

errorMessage - the error message

executeTask

public void executeTask(long jobId,
                        int taskId,
                        JobConfig jobConfig,
                        Serializable taskArgs,
                        RunTaskContext context)

Executes the given task.

Parameters:

jobId - the job id

taskId - the task id

jobConfig - the job configuration

taskArgs - the arguments

context - the context of the worker

cancelTask

public void cancelTask(long jobId,
                       int taskId)

Cancels the given task.

Parameters:

jobId - the job id

taskId - the task id

getAndClearTaskUpdates

public List<TaskInfo> getAndClearTaskUpdates()

Returns:

the list of task information

restoreTaskUpdates

public void restoreTaskUpdates(List<TaskInfo> tasks)

Adds the given tasks to the task updates data structure. If there is already an update for the specified task, it is not changed.

Parameters:

tasks - the tasks to restore