alluxio.master.job

Class LoadJob.LoadTask

java.lang.Object

alluxio.scheduler.job.Task<LoadResponse>

alluxio.master.job.LoadJob.LoadTask

Enclosing class:

LoadJob

public class LoadJob.LoadTask
extends Task<LoadResponse>

Loads blocks in a UFS through an Alluxio worker.

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

execute, getResponseFuture

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, 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>