org.apache.hadoop.mapred

类 JobStatus

java.lang.Object

org.apache.hadoop.mapred.JobStatus

所有已实现的接口:

Cloneable, Writable

public class JobStatus
extends Object
implements Writable, Cloneable

Describes the current status of a job.

另请参阅:

for some more information.

字段概要

字段

限定符和类型	字段和说明
static int	FAILED
static int	KILLED
static int	PREP
static int	RUNNING
static int	SUCCEEDED

构造器概要

构造器

构造器和说明
JobStatus()
JobStatus(JobID jobid, float setupProgress, float mapProgress, float reduceProgress, float cleanupProgress, int runState, JobPriority jp) Create a job status object for a given jobid.
JobStatus(JobID jobid, float mapProgress, float reduceProgress, float cleanupProgress, int runState) Create a job status object for a given jobid.
JobStatus(JobID jobid, float mapProgress, float reduceProgress, float cleanupProgress, int runState, JobPriority jp) Create a job status object for a given jobid.
JobStatus(JobID jobid, float mapProgress, float reduceProgress, int runState) Create a job status object for a given jobid.

方法概要

方法

限定符和类型	方法和说明
float	cleanupProgress()
Object	clone()
String	getFailureInfo() gets any available info on the reason of failure of the job.
Map<JobACL,AccessControlList>	getJobACLs() Get the acls for Job.
String	getJobId() 已过时。 use getJobID instead
JobID	getJobID()
JobPriority	getJobPriority() Return the priority of the job
static String	getJobRunState(int state) Helper method to get human-readable state of the job.
int	getRunState()
String	getSchedulingInfo() Gets the Scheduling information associated to a particular Job.
long	getStartTime()
String	getUsername()
boolean	isJobComplete() Returns true if the status is for a completed job.
float	mapProgress()
void	readFields(DataInput in) Deserialize the fields of this object from in.
float	reduceProgress()
void	setFailureInfo(String failureInfo) set the reason for failuire of this job
protected void	setJobACLs(Map<JobACL,AccessControlList> acls) Set the job acls
void	setJobPriority(JobPriority jp) Set the priority of the job, defaulting to NORMAL.
void	setRunState(int state) Change the current run state of the job.
void	setSchedulingInfo(String schedulingInfo) Used to set the scheduling information associated to a particular Job.
float	setupProgress()
void	write(DataOutput out) Serialize the fields of this object to out.

从类继承的方法 java.lang.Object

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

字段详细资料

RUNNING

public static final int RUNNING

另请参阅:

常量字段值

SUCCEEDED

public static final int SUCCEEDED

另请参阅:

常量字段值

FAILED

public static final int FAILED

另请参阅:

常量字段值

PREP

public static final int PREP

另请参阅:

常量字段值

KILLED

public static final int KILLED

另请参阅:

常量字段值

构造器详细资料

JobStatus

public JobStatus()

JobStatus

public JobStatus(JobID jobid,
         float mapProgress,
         float reduceProgress,
         float cleanupProgress,
         int runState)

Create a job status object for a given jobid.

参数:

jobid - The jobid of the job

mapProgress - The progress made on the maps

reduceProgress - The progress made on the reduces

cleanupProgress - The progress made on cleanup

runState - The current state of the job

JobStatus

public JobStatus(JobID jobid,
         float mapProgress,
         float reduceProgress,
         int runState)

Create a job status object for a given jobid.

参数:

jobid - The jobid of the job

mapProgress - The progress made on the maps

reduceProgress - The progress made on the reduces

runState - The current state of the job

JobStatus

public JobStatus(JobID jobid,
         float mapProgress,
         float reduceProgress,
         float cleanupProgress,
         int runState,
         JobPriority jp)

Create a job status object for a given jobid.

参数:

jobid - The jobid of the job

mapProgress - The progress made on the maps

reduceProgress - The progress made on the reduces

runState - The current state of the job

jp - Priority of the job.

JobStatus

public JobStatus(JobID jobid,
         float setupProgress,
         float mapProgress,
         float reduceProgress,
         float cleanupProgress,
         int runState,
         JobPriority jp)

Create a job status object for a given jobid.

参数:

jobid - The jobid of the job

setupProgress - The progress made on the setup

mapProgress - The progress made on the maps

reduceProgress - The progress made on the reduces

cleanupProgress - The progress made on the cleanup

runState - The current state of the job

jp - Priority of the job.

方法详细资料

getJobRunState

public static String getJobRunState(int state)

Helper method to get human-readable state of the job.

参数:

state - job state

返回:

human-readable state of the job

getJobId

@Deprecated
public String getJobId()

已过时。 use getJobID instead

getJobID

public JobID getJobID()

返回:

The jobid of the Job

mapProgress

public float mapProgress()

返回:

Percentage of progress in maps

setJobACLs

protected void setJobACLs(Map<JobACL,AccessControlList> acls)

Set the job acls

参数:

acls - Map from JobACL to AccessControlList

cleanupProgress

public float cleanupProgress()

返回:

Percentage of progress in cleanup

setupProgress

public float setupProgress()

返回:

Percentage of progress in setup

reduceProgress

public float reduceProgress()

返回:

Percentage of progress in reduce

getRunState

public int getRunState()

返回:

running state of the job

setRunState

public void setRunState(int state)

Change the current run state of the job.

getStartTime

public long getStartTime()

返回:

start time of the job

clone

public Object clone()

覆盖:

clone 在类中 Object

getUsername

public String getUsername()

返回:

the username of the job

getSchedulingInfo

public String getSchedulingInfo()

Gets the Scheduling information associated to a particular Job.

返回:

the scheduling information of the job

getFailureInfo

public String getFailureInfo()

gets any available info on the reason of failure of the job.

返回:

diagnostic information on why a job might have failed.

setFailureInfo

public void setFailureInfo(String failureInfo)

set the reason for failuire of this job

参数:

failureInfo - the reason for failure of this job.

setSchedulingInfo

public void setSchedulingInfo(String schedulingInfo)

Used to set the scheduling information associated to a particular Job.

参数:

schedulingInfo - Scheduling information of the job

getJobACLs

public Map<JobACL,AccessControlList> getJobACLs()

Get the acls for Job.

返回:

a Map from JobACL to AccessControlList

getJobPriority

public JobPriority getJobPriority()

Return the priority of the job

返回:

job priority

setJobPriority

public void setJobPriority(JobPriority jp)

Set the priority of the job, defaulting to NORMAL.

参数:

jp - new job priority

isJobComplete

public boolean isJobComplete()

Returns true if the status is for a completed job.

write

public void write(DataOutput out)
           throws IOException

从接口复制的说明: Writable

Serialize the fields of this object to out.

指定者:

write 在接口中 Writable

参数:

out - DataOuput to serialize this object into.

抛出:

IOException

readFields

public void readFields(DataInput in)
                throws IOException

从接口复制的说明: Writable

Deserialize the fields of this object from in.

For efficiency, implementations should attempt to re-use storage in the existing object where possible.

指定者:

readFields 在接口中 Writable

参数:

in - DataInput to deseriablize this object from.

抛出:

IOException