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 Set<String>	mFailedFiles
protected Set<JobInfo>	mFailedTasks
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.
Set<String>	getFailedFiles() Get failed files if there's any.
abstract JobConfig	getJobConfig() Get job config.
abstract int	getSize() Get how many files contained in job attempt.
protected abstract void	logCompleted()
protected abstract void	logFailed()
protected abstract void	logFailedAttempt(JobInfo jobInfo)
boolean	run() Runs the job.
protected abstract void	setFailedFiles()

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

mFailedTasks

protected Set<JobInfo> mFailedTasks

mFailedFiles

protected Set<String> mFailedFiles

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

public abstract JobConfig getJobConfig()

Get job config.

Returns:

job config

getSize

public abstract int getSize()

Get how many files contained in job attempt.

Returns:

number of files

getFailedFiles

public Set<String> getFailedFiles()

Get failed files if there's any. Only call this function after confirm job status is FAILED!

Returns:

failed fail set

setFailedFiles

protected abstract void setFailedFiles()

logFailedAttempt

protected abstract void logFailedAttempt(JobInfo jobInfo)

logFailed

protected abstract void logFailed()

logCompleted

protected abstract void logCompleted()