alluxio.master.job

Class AbstractJob<T extends Task<?>>

java.lang.Object

alluxio.master.job.AbstractJob<T>

Type Parameters:

T - the type of the task of the job

All Implemented Interfaces:

Job<T>

Direct Known Subclasses:

LoadJob

public abstract class AbstractJob<T extends Task<?>>
extends Object
implements Job<T>

Abstract class for job. It provides basic job information and state management.

Field Summary

Fields

Modifier and Type	Field and Description
protected OptionalLong	mEndTime
protected String	mJobId
protected long	mStartTime
protected JobState	mState
protected Optional<String>	mUser

Constructor Summary

Constructors

Constructor and Description
AbstractJob(Optional<String> user, String jobId) Creates a new instance of AbstractJob.

Method Summary

Modifier and Type	Method and Description
OptionalLong	getEndTime() Get end time.
String	getJobId()
JobState	getJobState() Get load status.
boolean	isDone() Check whether the job is finished.
boolean	isRunning() Check whether the job is still running.
void	setEndTime(long time) Update end time.
void	setJobState(JobState state) Set load state.

Methods inherited from class java.lang.Object

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

Methods inherited from interface alluxio.scheduler.job.Job

failJob, getDescription, getNextTask, getProgress, initiateVerification, isCurrentPassDone, isHealthy, needVerification, processResponse, toJournalEntry, updateJob

Field Detail

mJobId

protected final String mJobId

mState

protected JobState mState

mEndTime

protected OptionalLong mEndTime

mStartTime

protected final long mStartTime

mUser

protected final Optional<String> mUser

Constructor Detail

AbstractJob

public AbstractJob(Optional<String> user,
                   String jobId)

Creates a new instance of AbstractJob.

Parameters:

user - the user who submitted the job

jobId - the job id

Method Detail

getJobId

public String getJobId()

Specified by:

getJobId in interface Job<T extends Task<?>>

Returns:

job id. unique id for the job

getEndTime

public OptionalLong getEndTime()

Get end time.

Specified by:

getEndTime in interface Job<T extends Task<?>>

Returns:

end time

setEndTime

public void setEndTime(long time)

Update end time.

Parameters:

time - time in ms

getJobState

public JobState getJobState()

Get load status.

Specified by:

getJobState in interface Job<T extends Task<?>>

Returns:

the load job's status

setJobState

public void setJobState(JobState state)

Set load state.

Specified by:

setJobState in interface Job<T extends Task<?>>

Parameters:

state - new state

isRunning

public boolean isRunning()

Description copied from interface: Job

Check whether the job is still running.

Specified by:

isRunning in interface Job<T extends Task<?>>

Returns:

true if the job is running, false if not

isDone

public boolean isDone()

Description copied from interface: Job

Check whether the job is finished.

Specified by:

isDone in interface Job<T extends Task<?>>

Returns:

true if the job is finished, false if not