alluxio.master.job.tracker

Class CmdRunAttempt

java.lang.Object

alluxio.master.job.tracker.CmdRunAttempt

public class CmdRunAttempt
extends Object

class for handling submission for a child job within a distributed command.

Field Summary

Fields

Modifier and Type	Field and Description
protected JobMaster	mJobMaster
protected RetryPolicy	mRetryPolicy

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	CmdRunAttempt(RetryPolicy retryPolicy, JobMaster jobMaster)

Method Summary

Modifier and Type	Method and Description
Status	checkJobStatus() Returns the status of the job.
long	getCreationTime() Returns the job creation time.
Set<String>	getFailedFiles() Return a copy of failed paths.
long	getFileCount() Get file count.
String	getFilePath() Set file path.
long	getFileSize() Get file size.
JobConfig	getJobConfig() Get job config.
Long	getJobId() Returns the job Id.
void	printFailed() Log failed file information.
boolean	run() Runs the job.
void	setConfig(JobConfig config) Set job config.
void	setFileCount(long fileCount) Set file count.
void	setFilePath(String filePath) Set file path.
void	setFileSize(long fileSize) Set file size.

Methods inherited from class java.lang.Object

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

Field Detail

mRetryPolicy

protected final RetryPolicy mRetryPolicy

mJobMaster

protected final JobMaster mJobMaster

Constructor Detail

CmdRunAttempt

protected CmdRunAttempt(RetryPolicy retryPolicy,
                        JobMaster jobMaster)

Method Detail

setConfig

public void setConfig(JobConfig config)

Set job config.

Parameters:

config - job config

setFileCount

public void setFileCount(long fileCount)

Set file count.

Parameters:

fileCount - file count

setFileSize

public void setFileSize(long fileSize)

Set file size.

Parameters:

fileSize - file size

setFilePath

public void setFilePath(String filePath)

Set file path.

Parameters:

filePath - file path

getJobConfig

public JobConfig getJobConfig()

Get job config.

Returns:

job config

getFileCount

public long getFileCount()

Get file count.

Returns:

file count

getFileSize

public long getFileSize()

Get file size.

Returns:

file size

getFilePath

public String getFilePath()

Set file path.

Returns:

the file path string

getCreationTime

public long getCreationTime()

Returns the job creation time.

Returns:

creation time of a job

run

public boolean run()

Runs the job.

Returns:

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

getJobId

public Long getJobId()

Returns the job Id.

Returns:

job Id

checkJobStatus

public Status checkJobStatus()

Returns the status of the job.

Returns:

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

printFailed

public void printFailed()

Log failed file information.

getFailedFiles

public Set<String> getFailedFiles()

Return a copy of failed paths.

Returns:

failed files