alluxio.job.meta

Class JobInfo

java.lang.Object

alluxio.job.meta.JobInfo

All Implemented Interfaces:

Comparable<JobInfo>

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

The job information used by the job master internally.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	addTask(int taskId) Registers a task.
int	compareTo(JobInfo 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<Integer>	getTaskIdList()
TaskInfo	getTaskInfo(int 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(int 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

JobInfo

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

Creates a new instance of JobInfo.

Parameters:

id - the job id

jobConfig - the job configuration

statusChangeCallback - the callback to invoke upon status change

Method Detail

compareTo

public int compareTo(JobInfo 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<JobInfo>

addTask

public void addTask(int taskId)

Registers a task.

Parameters:

taskId - the task id

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(int 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(int taskId,
                        TaskInfo taskInfo)

Sets the information of a task.

Parameters:

taskId - the task id

taskInfo - the task information

getTaskIdList

public List<Integer> 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