alluxio.scheduler.job

Class Task<V>

java.lang.Object

alluxio.scheduler.job.Task<V>

Type Parameters:

V - the response type of the task

All Implemented Interfaces:

Comparable<Task>

Direct Known Subclasses:

CopyJob.CopyTask, DoraLoadJob.DoraLoadTask, LoadJob.LoadTask, MoveJob.MoveTask

public abstract class Task<V>
extends Object
implements Comparable<Task>

A task that can be executed on a worker. Belongs to a Job.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Task.TaskStat Metrics and stats to track current task.

Field Summary

Fields

Modifier and Type	Field and Description
protected Job	mMyJob

Constructor Summary

Constructors

Constructor and Description
Task(Job job, int taskId) constructs Task.

Method Summary

Modifier and Type	Method and Description
int	compareTo(Task o)
boolean	equals(Object obj)
void	execute(BlockWorkerClient client, WorkerInfo workerInfo) run the task and set the response future.
Job	getJob() Get the job this task belongs to.
WorkerInfo	getMyRunningWorker() Get the worker info this task runs on.
int	getPriority()
com.google.common.util.concurrent.ListenableFuture<V>	getResponseFuture()
int	getTaskId() Get task id.
Task.TaskStat	getTaskStat()
int	hashCode()
protected abstract com.google.common.util.concurrent.ListenableFuture<V>	run(BlockWorkerClient client) run the task.
void	setJob(Job job) Set the job.
void	setMyRunningWorker(WorkerInfo workerInfo) Set the worker info this task runs on.
void	setPriority(int priority) Set priority.
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Detail

mMyJob

protected Job mMyJob

Constructor Detail

Task

public Task(Job job,
            int taskId)

constructs Task.

Parameters:

job -

taskId -

Method Detail

run

protected abstract com.google.common.util.concurrent.ListenableFuture<V> run(BlockWorkerClient client)

run the task.

getMyRunningWorker

public WorkerInfo getMyRunningWorker()

Get the worker info this task runs on.

Returns:

my running worker

setMyRunningWorker

public void setMyRunningWorker(WorkerInfo workerInfo)

Set the worker info this task runs on.

Parameters:

workerInfo -

getTaskId

public int getTaskId()

Get task id.

Returns:

taskId

getResponseFuture

public com.google.common.util.concurrent.ListenableFuture<V> getResponseFuture()

Returns:

the response future

execute

public void execute(BlockWorkerClient client,
                    WorkerInfo workerInfo)

run the task and set the response future.

Parameters:

client - worker client

workerInfo - the worker information

setJob

public void setJob(Job job)

Set the job.

Parameters:

job - the job

getJob

public Job getJob()

Get the job this task belongs to.

Returns:

Job

getTaskStat

public Task.TaskStat getTaskStat()

Returns:

task stat

getPriority

public int getPriority()

Returns:

priority

setPriority

public void setPriority(int priority)

Set priority.

Parameters:

priority -

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

compareTo

public int compareTo(Task o)

Specified by:

compareTo in interface Comparable<Task>

toString

public String toString()

Overrides:

toString in class Object