org.apache.hadoop.mapred.jobcontrol

类 Job

java.lang.Object

org.apache.hadoop.mapred.jobcontrol.Job

public class Job
extends Object

This class encapsulates a MapReduce job and its dependency. It monitors the states of the depending jobs and updates the state of this job. A job starts in the WAITING state. If it does not have any depending jobs, or all of the depending jobs are in SUCCESS state, then the job state will become READY. If any depending jobs fail, the job will fail too. When in READY state, the job can be submitted to Hadoop for execution, with the state changing into RUNNING state. From RUNNING state, the job can get into SUCCESS or FAILED state, depending the status of the job execution.

字段概要

字段

限定符和类型	字段和说明
static int	DEPENDENT_FAILED
static int	FAILED
static int	READY
static int	RUNNING
static int	SUCCESS
static int	WAITING

构造器概要

构造器

构造器和说明
Job(JobConf jobConf) Construct a job.
Job(JobConf jobConf, ArrayList<Job> dependingJobs) Construct a job.

方法概要

方法

限定符和类型	方法和说明
boolean	addDependingJob(Job dependingJob) Add a job to this jobs' dependency list.
JobID	getAssignedJobID()
ArrayList<Job>	getDependingJobs()
JobClient	getJobClient()
JobConf	getJobConf()
String	getJobID()
String	getJobName()
String	getMapredJobID() 已过时。 use getAssignedJobID() instead
String	getMessage()
int	getState()
boolean	isCompleted()
boolean	isReady()
void	setAssignedJobID(JobID mapredJobID) Set the mapred ID for this job as assigned by the mapred framework.
void	setJobConf(JobConf jobConf) Set the mapred job conf for this job.
void	setJobID(String id) Set the job ID for this job.
void	setJobName(String jobName) Set the job name for this job.
void	setMapredJobID(String mapredJobID) 已过时。 use setAssignedJobID(JobID) instead
void	setMessage(String message) Set the message for this job.
protected void	setState(int state) Set the state for this job.
protected void	submit() Submit this job to mapred.
String	toString()

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

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

字段详细资料

SUCCESS

public static final int SUCCESS

另请参阅:

常量字段值

WAITING

public static final int WAITING

另请参阅:

常量字段值

RUNNING

public static final int RUNNING

另请参阅:

常量字段值

READY

public static final int READY

另请参阅:

常量字段值

FAILED

public static final int FAILED

另请参阅:

常量字段值

DEPENDENT_FAILED

public static final int DEPENDENT_FAILED

另请参阅:

常量字段值

构造器详细资料

Job

public Job(JobConf jobConf,
   ArrayList<Job> dependingJobs)
    throws IOException

Construct a job.

参数:

jobConf - a mapred job configuration representing a job to be executed.

dependingJobs - an array of jobs the current job depends on

抛出:

IOException

Job

public Job(JobConf jobConf)
    throws IOException

Construct a job.

参数:

jobConf - mapred job configuration representing a job to be executed.

抛出:

IOException

方法详细资料

toString

public String toString()

覆盖:

toString 在类中 Object

getJobName

public String getJobName()

返回:

the job name of this job

setJobName

public void setJobName(String jobName)

Set the job name for this job.

参数:

jobName - the job name

getJobID

public String getJobID()

返回:

the job ID of this job assigned by JobControl

setJobID

public void setJobID(String id)

Set the job ID for this job.

参数:

id - the job ID

getMapredJobID

@Deprecated
public String getMapredJobID()

已过时。 use getAssignedJobID() instead

返回:

the mapred ID of this job

setMapredJobID

@Deprecated
public void setMapredJobID(String mapredJobID)

已过时。 use setAssignedJobID(JobID) instead

Set the mapred ID for this job.

参数:

mapredJobID - the mapred job ID for this job.

getAssignedJobID

public JobID getAssignedJobID()

返回:

the mapred ID of this job as assigned by the mapred framework.

setAssignedJobID

public void setAssignedJobID(JobID mapredJobID)

Set the mapred ID for this job as assigned by the mapred framework.

参数:

mapredJobID - the mapred job ID for this job.

getJobConf

public JobConf getJobConf()

返回:

the mapred job conf of this job

setJobConf

public void setJobConf(JobConf jobConf)

Set the mapred job conf for this job.

参数:

jobConf - the mapred job conf for this job.

getState

public int getState()

返回:

the state of this job

setState

protected void setState(int state)

Set the state for this job.

参数:

state - the new state for this job.

getMessage

public String getMessage()

返回:

the message of this job

setMessage

public void setMessage(String message)

Set the message for this job.

参数:

message - the message for this job.

getJobClient

public JobClient getJobClient()

返回:

the job client of this job

getDependingJobs

public ArrayList<Job> getDependingJobs()

返回:

the depending jobs of this job

addDependingJob

public boolean addDependingJob(Job dependingJob)

Add a job to this jobs' dependency list. Dependent jobs can only be added while a Job is waiting to run, not during or afterwards.

参数:

dependingJob - Job that this Job depends on.

返回:

true if the Job was added.

isCompleted

public boolean isCompleted()

返回:

true if this job is in a complete state

isReady

public boolean isReady()

返回:

true if this job is in READY state

submit

protected void submit()

Submit this job to mapred. The state becomes RUNNING if submission is successful, FAILED otherwise.