@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 |
---|---|
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)
Deprecated.
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)
Deprecated.
|
protected void |
setState(int state)
Deprecated.
|
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()
@Deprecated protected void setState(int state)
state
- the new state for this job.public boolean addDependingJob(Job dependingJob)
dependingJob
- Job that this Job depends on.public JobClient getJobClient()
public String getMapredJobID()
@Deprecated public void setMapredJobID(String mapredJobID)
mapredJobID
- the mapred job ID for this job.Copyright © 2024 Apache Software Foundation. All rights reserved.