alluxio.master.job

Class LoadJob.LoadTask

java.lang.Object

alluxio.scheduler.job.Task<LoadResponse>

alluxio.master.job.LoadJob.LoadTask

All Implemented Interfaces:

Comparable<Task>

Enclosing class:

LoadJob

public class LoadJob.LoadTask
extends Task<LoadResponse>

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
LoadTask(List<Block> blocks) Creates a new instance of LoadJob.LoadTask.

Method Summary

Modifier and Type	Method and Description
List<Block>	getBlocks()
com.google.common.util.concurrent.ListenableFuture<LoadResponse>	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

LoadTask

public LoadTask(List<Block> blocks)

Creates a new instance of LoadJob.LoadTask.

Parameters:

blocks - blocks to load

Method Detail

getBlocks

public List<Block> getBlocks()

Returns:

blocks to load

run

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

Description copied from class: Task

run the task.

Specified by:

run in class Task<LoadResponse>