@InterfaceAudience.Public @InterfaceStability.Evolving public class ControlledJob extends Object
限定符和类型 | 类和说明 |
---|---|
static class |
ControlledJob.State |
限定符和类型 | 字段和说明 |
---|---|
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() |
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(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() |
public ControlledJob(Job job, List<ControlledJob> dependingJobs) throws IOException
job
- a mapreduce job to be executed.dependingJobs
- an array of jobs the current job depends onIOException
public ControlledJob(Configuration conf) throws IOException
conf
- mapred job configuration representing a job to be executed.IOException
public String getJobName()
public void setJobName(String jobName)
jobName
- the job namepublic String getJobID()
public void setJobID(String id)
id
- the job IDpublic JobID getMapredJobID()
public Job getJob()
public void setJob(Job job)
job
- the mapreduce job for this job.public ControlledJob.State getJobState()
protected void setJobState(ControlledJob.State state)
state
- the new state for this job.public String getMessage()
public void setMessage(String message)
message
- the message for this job.public List<ControlledJob> getDependentJobs()
public boolean addDependingJob(ControlledJob dependingJob)
dependingJob
- Job that this Job depends on.public boolean isCompleted()
public boolean isReady()
public void killJob() throws IOException, InterruptedException
public void failJob(String message) throws IOException, InterruptedException
protected void submit()
Copyright © 2009 The Apache Software Foundation