@InterfaceAudience.Public @InterfaceStability.Stable public class Job extends ControlledJob
Modifier and Type | Field and Description |
---|---|
static int |
DEPENDENT_FAILED |
static int |
FAILED |
static int |
READY |
static int |
RUNNING |
static int |
SUCCESS |
static int |
WAITING |
CREATE_DIR
Constructor and Description |
---|
Job(JobConf conf) |
Job(JobConf jobConf,
ArrayList<?> dependingJobs)
Construct a job.
|
Modifier and Type | Method and Description |
---|---|
JobID |
getAssignedJobID() |
ArrayList<Job> |
getDependingJobs() |
JobClient |
getJobClient() |
JobConf |
getJobConf() |
int |
getState() |
void |
setAssignedJobID(JobID mapredJobID)
Deprecated.
setAssignedJobID should not be called.
JOBID is set by the framework.
|
void |
setJobConf(JobConf jobConf)
Set the mapred job conf for this job.
|
addDependingJob, failJob, getDependentJobs, getJob, getJobID, getJobName, getJobState, getMapredJobID, getMessage, isCompleted, isReady, killJob, setJob, setJobID, setJobName, setJobState, setMessage, submit, toString
public static final int SUCCESS
public static final int WAITING
public static final int RUNNING
public static final int READY
public static final int FAILED
public static final int DEPENDENT_FAILED
public Job(JobConf jobConf, ArrayList<?> dependingJobs) throws IOException
jobConf
- a mapred job configuration representing a job to be executed.dependingJobs
- an array of jobs the current job depends onIOException
public Job(JobConf conf) throws IOException
IOException
public JobID getAssignedJobID()
@Deprecated public void setAssignedJobID(JobID mapredJobID)
public JobConf getJobConf()
public void setJobConf(JobConf jobConf)
jobConf
- the mapred job conf for this job.public int getState()
public JobClient getJobClient()
public ArrayList<Job> getDependingJobs()
Copyright © 2014 Apache Software Foundation. All Rights Reserved.