alluxio.job.plan.meta

Class PlanInfo

java.lang.Object

alluxio.job.plan.meta.PlanInfo

All Implemented Interfaces:

Comparable<PlanInfo>

@ThreadSafe
public final class PlanInfo
extends Object
implements Comparable<PlanInfo>

The job information used by the job master internally.

Constructor Summary

Constructors

Constructor and Description
PlanInfo(long id, JobConfig jobConfig, java.util.function.Consumer<PlanInfo> statusChangeCallback) Creates a new instance of PlanInfo.

Method Summary

Modifier and Type	Method and Description
void	addTask(long taskId, WorkerInfo workerInfo, Object args) Registers a task.
int	compareTo(PlanInfo other) This method orders jobs using the time their status was last modified.
boolean	equals(Object o)
String	getErrorMessage()
long	getId()
JobConfig	getJobConfig()
long	getLastStatusChangeMs()
String	getResult()
Status	getStatus()
List<Long>	getTaskIdList()
TaskInfo	getTaskInfo(long taskId)
List<TaskInfo>	getTaskInfoList()
int	hashCode()
void	setErrorMessage(String errorMessage)
void	setResult(String result)
void	setStatus(Status status) Sets the status of a job.
void	setTaskInfo(long taskId, TaskInfo taskInfo) Sets the information of a task.

Methods inherited from class java.lang.Object

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

Constructor Detail

PlanInfo

public PlanInfo(long id,
                JobConfig jobConfig,
                java.util.function.Consumer<PlanInfo> statusChangeCallback)

Creates a new instance of PlanInfo.

Parameters:

id - the job id

jobConfig - the job configuration

statusChangeCallback - the callback to invoke upon status change

Method Detail

compareTo

public int compareTo(PlanInfo other)

This method orders jobs using the time their status was last modified. If the status is equal, they are compared by jobId

Specified by:

compareTo in interface Comparable<PlanInfo>

addTask

public void addTask(long taskId,
                    WorkerInfo workerInfo,
                    Object args)

Registers a task.

Parameters:

taskId - the task id

workerInfo - the worker info

args - the arguments

getId

public long getId()

Returns:

the job id

getJobConfig

public JobConfig getJobConfig()

Returns:

the job configuration

getLastStatusChangeMs

public long getLastStatusChangeMs()

Returns:

the time when the job status was last changed (in milliseconds)

setErrorMessage

public void setErrorMessage(String errorMessage)

Parameters:

errorMessage - the error message

getErrorMessage

public String getErrorMessage()

Returns:

the error message

getTaskInfo

public TaskInfo getTaskInfo(long taskId)

Parameters:

taskId - the task ID to get the task info for

Returns:

the task info, or null if the task ID doesn't exist

setTaskInfo

public void setTaskInfo(long taskId,
                        TaskInfo taskInfo)

Sets the information of a task.

Parameters:

taskId - the task id

taskInfo - the task information

getTaskIdList

public List<Long> getTaskIdList()

Returns:

the list of task ids

setStatus

public void setStatus(Status status)

Sets the status of a job. A job can only move from one status to another if the job hasn't already finished. If a job is finished and the caller tries to change the status, this method is a no-op.

Parameters:

status - the job status

getStatus

public Status getStatus()

Returns:

the status of the job

setResult

public void setResult(String result)

Parameters:

result - the joined job result

getResult

public String getResult()

Returns:

the result of the job

getTaskInfoList

public List<TaskInfo> getTaskInfoList()

Returns:

the list of task information

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object