configuration.
You can get the Job instance by calling
getInstance
method.
Ex:
Job job =
Job.getInstance(conf, "word count");
Once you got
the Job instance, you can specify Mapper, combiner, Partitioner, Reducer,
InputFormat, OutputFormat implementations by using setter methods of the Job
instance.
For an
example, go through the link.
How to submit a job
By using
following methods, you can submit a job.
Job.submit(): Submit the job to the cluster and return
immediately.
Job.waitForCompletion(boolean): Submit the job to the cluster and wait
for it to finish.
No comments:
Post a Comment