com.cloudera.crunch.impl.mr.exec
Class CrunchJob

java.lang.Object
  org.apache.hadoop.mapreduce.lib.jobcontrol.ControlledJob
      com.cloudera.crunch.impl.mr.exec.CrunchJob

public class CrunchJob
extends ControlledJob

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.lib.jobcontrol.ControlledJob

ControlledJob.State

Field Summary

Fields inherited from class org.apache.hadoop.mapreduce.lib.jobcontrol.ControlledJob

CREATE_DIR, job, message, state

Constructor Summary

CrunchJob(org.apache.hadoop.mapreduce.Job job, org.apache.hadoop.fs.Path workingPath, MSCROutputHandler handler)

Method Summary

protected void	checkRunningState() Check the state of this running job.
protected void	submit() Submit this job to mapred.

Methods inherited from class org.apache.hadoop.mapreduce.lib.jobcontrol.ControlledJob

addDependingJob, getDependentJobs, getJob, getJobID, getJobName, getJobState, getMapredJobID, getMessage, isCompleted, isReady, killJob, setJob, setJobID, setJobName, setJobState, setMessage, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

CrunchJob

public CrunchJob(org.apache.hadoop.mapreduce.Job job,
                 org.apache.hadoop.fs.Path workingPath,
                 MSCROutputHandler handler)
          throws IOException

Throws:

IOException

Method Detail

checkRunningState

protected void checkRunningState()
                          throws IOException,
                                 InterruptedException

Description copied from class: ControlledJob

Check the state of this running job. The state may remain the same, become SUCCESS or FAILED.

Overrides:

checkRunningState in class ControlledJob

Throws:

IOException

InterruptedException

submit

protected void submit()

Description copied from class: ControlledJob

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

Overrides:

submit in class ControlledJob