alluxio.master.job

Class CopyJob.CopyTask

java.lang.Object

alluxio.scheduler.job.Task<CopyResponse>

alluxio.master.job.CopyJob.CopyTask

All Implemented Interfaces:

Comparable<Task>

Enclosing class:

CopyJob

public class CopyJob.CopyTask
extends Task<CopyResponse>

Loads blocks in a UFS through an Alluxio worker.

Nested Class Summary

Nested classes/interfaces inherited from class alluxio.scheduler.job.Task

Task.TaskStat

Field Summary

Fields inherited from class alluxio.scheduler.job.Task

mMyJob

Constructor Summary

Constructors

Constructor and Description
CopyTask(List<Route> routes) Creates a new instance of CopyJob.CopyTask.

Method Summary

Modifier and Type	Method and Description
int	compareTo(Task o)
List<Route>	getRoutes()
com.google.common.util.concurrent.ListenableFuture<CopyResponse>	run(BlockWorkerClient workerClient) run the task.

Methods inherited from class alluxio.scheduler.job.Task

equals, execute, getJob, getMyRunningWorker, getPriority, getResponseFuture, getTaskId, getTaskStat, hashCode, setJob, setMyRunningWorker, setPriority, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

CopyTask

public CopyTask(List<Route> routes)

Creates a new instance of CopyJob.CopyTask.

Parameters:

routes - pair of source and destination files

Method Detail

getRoutes

public List<Route> getRoutes()

Returns:

blocks to load

run

public com.google.common.util.concurrent.ListenableFuture<CopyResponse> run(BlockWorkerClient workerClient)

Description copied from class: Task

run the task.

Specified by:

run in class Task<CopyResponse>

compareTo

public int compareTo(Task o)

Specified by:

compareTo in interface Comparable<Task>

Overrides:

compareTo in class Task<CopyResponse>