alluxio.master.job

Class MoveJob.MoveTask

java.lang.Object

alluxio.scheduler.job.Task<MoveResponse>

alluxio.master.job.MoveJob.MoveTask

All Implemented Interfaces:

Comparable<Task>

Enclosing class:

MoveJob

public class MoveJob.MoveTask
extends Task<MoveResponse>

Moves 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
MoveTask(List<Route> routes) Creates a new instance of MoveJob.MoveTask.

Method Summary

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

Methods inherited from class alluxio.scheduler.job.Task

compareTo, 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

MoveTask

public MoveTask(List<Route> routes)

Creates a new instance of MoveJob.MoveTask.

Parameters:

routes - pair of source and destination files

Method Detail

getRoutes

public List<Route> getRoutes()

Returns:

blocks to move

run

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

Description copied from class: Task

run the task.

Specified by:

run in class Task<MoveResponse>