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-
Search WWH ::




Custom Search