alluxio.cli.fs.command.job

Class JobAttempt

java.lang.Object

alluxio.cli.fs.command.job.JobAttempt

public abstract class JobAttempt
extends Object

Abstract class for handling submission for a job.

Field Summary

Fields

Modifier and Type	Field and Description
protected JobMasterClient	mClient
protected RetryPolicy	mRetryPolicy

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	JobAttempt(JobMasterClient client, RetryPolicy retryPolicy)

Method Summary

Modifier and Type	Method and Description
Status	check() Returns the status of the job attempt.
protected abstract JobConfig	getJobConfig()
protected abstract void	logCompleted()
protected abstract void	logFailed()
protected abstract void	logFailedAttempt(JobInfo jobInfo)
boolean	run() Runs the job.

Methods inherited from class java.lang.Object

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

Field Detail

mClient

protected final JobMasterClient mClient

mRetryPolicy

protected final RetryPolicy mRetryPolicy

Constructor Detail

JobAttempt

protected JobAttempt(JobMasterClient client,
                     RetryPolicy retryPolicy)

Method Detail

run

public boolean run()

Runs the job.

Returns:

true if an attempt was made, false if attempts ran out

check

public Status check()

Returns the status of the job attempt.

Returns:

True if finished successfully or cancelled, False if FAILED and should be retried, null if the status should be checked again later

getJobConfig

protected abstract JobConfig getJobConfig()

logFailedAttempt

protected abstract void logFailedAttempt(JobInfo jobInfo)

logFailed

protected abstract void logFailed()

logCompleted

protected abstract void logCompleted()