org.apache.hadoop.mapred.jobcontrol

クラス Job

java.lang.Object

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

org.apache.hadoop.mapred.jobcontrol.Job

@InterfaceAudience.Public
 @InterfaceStability.Stable
public class Job
extends ControlledJob

フィールドのサマリー

フィールド

修飾子とタイプ	フィールドと説明
static int	DEPENDENT_FAILED
static int	FAILED
static int	READY
static int	RUNNING
static int	SUCCESS
static int	WAITING

クラスから継承されたフィールド org.apache.hadoop.mapreduce.lib.jobcontrol.ControlledJob

CREATE_DIR

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

コンストラクタ

コンストラクタと説明
Job(JobConf conf)
Job(JobConf jobConf, ArrayList<?> 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	getMapredJobID()
int	getState()
void	setAssignedJobID(JobID mapredJobID) 非推奨です。 setAssignedJobID should not be called. JOBID is set by the framework.
void	setJobConf(JobConf jobConf) Set the mapred job conf for this job.
void	setMapredJobID(String mapredJobID) 非推奨です。
protected void	setState(int state) 非推奨です。

クラスから継承されたメソッド org.apache.hadoop.mapreduce.lib.jobcontrol.ControlledJob

addDependingJob, failJob, getDependentJobs, getJob, getJobID, getJobName, getJobState, getMapredJobId, getMessage, isCompleted, isReady, killJob, setJob, setJobID, setJobName, setJobState, setMessage, submit, 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<?> 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 conf)
    throws IOException

例外:

IOException

メソッドの詳細

getAssignedJobID

public JobID getAssignedJobID()

戻り値:

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

setAssignedJobID

@Deprecated
public void setAssignedJobID(JobID mapredJobID)

非推奨です。 setAssignedJobID should not be called. JOBID is set by the framework.

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

@Deprecated
protected void setState(int state)

非推奨です。

This is a no-op function, Its a behavior change from 1.x We no more can change the state from job

パラメータ:

state - the new state for 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.

getJobClient

public JobClient getJobClient()

戻り値:

the job client of this job

getDependingJobs

public ArrayList<Job> getDependingJobs()

戻り値:

the depending jobs of this job

getMapredJobID

public String getMapredJobID()

戻り値:

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

setMapredJobID

@Deprecated
public void setMapredJobID(String mapredJobID)

非推奨です。

This is no-op method for backward compatibility. It's a behavior change from 1.x, we can not change job ids from job.

パラメータ:

mapredJobID - the mapred job ID for this job.