alluxio.master.job

Class DoraLoadJob.DoraLoadTask

java.lang.Object

alluxio.scheduler.job.Task<LoadFileResponse>

alluxio.master.job.DoraLoadJob.DoraLoadTask

All Implemented Interfaces:

Comparable<Task>

Enclosing class:

DoraLoadJob

public class DoraLoadJob.DoraLoadTask
extends Task<LoadFileResponse>

Dora load task.

Nested Class Summary

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

Task.TaskStat

Field Summary

Fields

Modifier and Type	Field and Description
protected List<UfsStatus>	mFilesToLoad

Fields inherited from class alluxio.scheduler.job.Task

mMyJob

Constructor Summary

Constructors

Constructor and Description
DoraLoadTask() Constructor.
DoraLoadTask(List<UfsStatus> filesToLoad) Constructor.

Method Summary

Modifier and Type	Method and Description
List<UfsStatus>	getFilesToLoad() Get files to load of this task.
protected com.google.common.util.concurrent.ListenableFuture<LoadFileResponse>	run(BlockWorkerClient workerClient) run the task.
String	toString()

Methods inherited from class alluxio.scheduler.job.Task

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

Methods inherited from class java.lang.Object

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

Field Detail

mFilesToLoad

protected List<UfsStatus> mFilesToLoad

Constructor Detail

DoraLoadTask

public DoraLoadTask()

Constructor.

DoraLoadTask

public DoraLoadTask(List<UfsStatus> filesToLoad)

Constructor.

Parameters:

filesToLoad - the file to load

Method Detail

getFilesToLoad

public List<UfsStatus> getFilesToLoad()

Get files to load of this task.

Returns:

list of UfsStatus

run

protected com.google.common.util.concurrent.ListenableFuture<LoadFileResponse> run(BlockWorkerClient workerClient)

Description copied from class: Task

run the task.

Specified by:

run in class Task<LoadFileResponse>

toString

public String toString()

Overrides:

toString in class Task<LoadFileResponse>