org.apache.hadoop.mapreduce.lib.jobcontrol

クラス ControlledJob

java.lang.Object

org.apache.hadoop.mapreduce.lib.jobcontrol.ControlledJob

直系の既知のサブクラス:

Job

@InterfaceAudience.Public
 @InterfaceStability.Evolving
public class ControlledJob
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 String	CREATE_DIR

コンストラクタのサマリー

コンストラクタ

コンストラクタと説明
ControlledJob(Configuration conf) Construct a job.
ControlledJob(Job job, List<ControlledJob> dependingJobs) Construct a job.

メソッドのサマリー

修飾子とタイプ	メソッドと説明
boolean	addDependingJob(ControlledJob dependingJob) Add a job to this jobs' dependency list.
void	failJob(String message)
List<ControlledJob>	getDependentJobs()
Job	getJob()
String	getJobID()
String	getJobName()
org.apache.hadoop.mapreduce.lib.jobcontrol.ControlledJob.State	getJobState()
JobID	getMapredJobId()
String	getMessage()
boolean	isCompleted()
boolean	isReady()
void	killJob()
void	setJob(Job job) Set the mapreduce job
void	setJobID(String id) Set the job ID for this job.
void	setJobName(String jobName) Set the job name for this job.
protected void	setJobState(org.apache.hadoop.mapreduce.lib.jobcontrol.ControlledJob.State state) Set the state for this job.
void	setMessage(String message) Set the message 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

フィールドの詳細

CREATE_DIR

public static final String CREATE_DIR

関連項目:

定数フィールド値

コンストラクタの詳細

ControlledJob

public ControlledJob(Job job,
                     List<ControlledJob> dependingJobs)
              throws IOException

Construct a job.

パラメータ:

job - a mapreduce job to be executed.

dependingJobs - an array of jobs the current job depends on

例外:

IOException

ControlledJob

public ControlledJob(Configuration conf)
              throws IOException

Construct a job.

パラメータ:

conf - 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

public JobID getMapredJobId()

戻り値:

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

getJob

public Job getJob()

戻り値:

the mapreduce job

setJob

public void setJob(Job job)

Set the mapreduce job

パラメータ:

job - the mapreduce job for this job.

getJobState

public org.apache.hadoop.mapreduce.lib.jobcontrol.ControlledJob.State getJobState()

戻り値:

the state of this job

setJobState

protected void setJobState(org.apache.hadoop.mapreduce.lib.jobcontrol.ControlledJob.State 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.

getDependentJobs

public List<ControlledJob> getDependentJobs()

戻り値:

the depending jobs of this job

addDependingJob

public boolean addDependingJob(ControlledJob 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

killJob

public void killJob()
             throws IOException,
                    InterruptedException

例外:

IOException

InterruptedException

failJob

public void failJob(String message)
             throws IOException,
                    InterruptedException

例外:

IOException

InterruptedException

submit

protected void submit()

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