Database Reference
In-Depth Information
Figure 7-1. How Hadoop runs a MapReduce job
Job Submission
The
submit()
method on
Job
creates an internal
JobSubmitter
instance and calls
submitJobInternal()
on it (step 1 in
Figure 7-1
). Having submitted the job,
waitForCompletion()
polls the job's progress once per second and reports the pro-
gress to the console if it has changed since the last report. When the job completes suc-