alluxio.worker.job.task

Class TaskExecutor

java.lang.Object

alluxio.worker.job.task.TaskExecutor

All Implemented Interfaces:

Runnable

@NotThreadSafe
public final class TaskExecutor
extends Object
implements Runnable

A thread that runs the task.

Constructor Summary

Constructors

Constructor and Description
TaskExecutor(long jobId, int taskId, JobConfig jobConfig, Serializable taskArgs, RunTaskContext context, TaskExecutorManager taskExecutorManager) Creates a new instance of TaskExecutor.

Method Summary

Modifier and Type	Method and Description
void	run()

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskExecutor

public TaskExecutor(long jobId,
                    int taskId,
                    JobConfig jobConfig,
                    Serializable taskArgs,
                    RunTaskContext context,
                    TaskExecutorManager taskExecutorManager)

Creates a new instance of TaskExecutor.

Parameters:

jobId - the job id

taskId - the task id

jobConfig - the job configuration

taskArgs - the arguments passed to the task

context - the context on the worker

taskExecutorManager - the task executor manager

Method Detail

run

public void run()

Specified by:

run in interface Runnable