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:

CopyJob, DoraLoadJob, LoadJob, MoveJob

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 LinkedHashSet<T>	mRetryTaskList
protected long	mStartTime
protected JobState	mState
protected AtomicInteger	mTaskIdGenerator
protected Optional<String>	mUser
protected WorkerAssignPolicy	mWorkerAssignPolicy

Constructor Summary

Constructors

Constructor and Description
AbstractJob(Optional<String> user, String jobId) Creates a new instance of AbstractJob.
AbstractJob(Optional<String> user, String jobId, WorkerAssignPolicy workerAssignPolicy) 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.
WorkerAssignPolicy	getWorkerAssignPolicy() Gets the worker assign policy.
void	initializeJob() Initialize the job before kick it running.
boolean	isDone() Check whether the job is finished.
boolean	isRunning() Check whether the job is still running.
void	onTaskSubmitFailure(Task<?> task) Define how to process task that gets rejected when scheduler tried to kick off.
void	setEndTime(long time) Update end time.
void	setJobState(JobState state, boolean journalUpdate) Set load state.
void	setStartTime(long time) Update start time.
void	setWorkerAssignPolicy(WorkerAssignPolicy assignPolicy) Sets the worker assign policy.

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, getNextTasks, getProgress, hasFailure, initiateVerification, isCurrentPassDone, isHealthy, needVerification, processResponse, setJobSuccess, toJournalEntry

Field Detail

mJobId

protected final String mJobId

mTaskIdGenerator

protected final AtomicInteger mTaskIdGenerator

mState

protected JobState mState

mEndTime

protected OptionalLong mEndTime

mStartTime

protected long mStartTime

mUser

protected final Optional<String> mUser

mRetryTaskList

protected final LinkedHashSet<T extends Task<?>> mRetryTaskList

mWorkerAssignPolicy

protected WorkerAssignPolicy mWorkerAssignPolicy

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

AbstractJob

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

Creates a new instance of AbstractJob.

Parameters:

user -

jobId -

workerAssignPolicy -

Method Detail

setWorkerAssignPolicy

public void setWorkerAssignPolicy(WorkerAssignPolicy assignPolicy)

Sets the worker assign policy.

Parameters:

assignPolicy - the assign policy

getWorkerAssignPolicy

public WorkerAssignPolicy getWorkerAssignPolicy()

Gets the worker assign policy.

Returns:

assignPolicy the assign policy

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

setStartTime

public void setStartTime(long time)

Update start time. This is for internal tests.

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,
                        boolean journalUpdate)

Set load state.

Specified by:

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

Parameters:

state - new state

journalUpdate - true if state change needs to be journaled

onTaskSubmitFailure

public void onTaskSubmitFailure(Task<?> task)

Description copied from interface: Job

Define how to process task that gets rejected when scheduler tried to kick off.

Specified by:

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

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

initializeJob

public void initializeJob()

Description copied from interface: Job

Initialize the job before kick it running.

Specified by:

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