Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Hadoop >> mail # user >> passing arguments to hadoop job

Copy link to this message
passing arguments to hadoop job
  Lets say I have the standard helloworld program

Now, lets say, I want to start the counting not from zero but from 200000.
So my reference line is 200000.

I modified the Reduce code as following:
 public static class Reduce extends MapReduceBase implements Reducer<Text,
IntWritable, Text, IntWritable> {
     *private static int baseSum ;*
*      public void configure(JobConf job){*
*      baseSum = Integer.parseInt(job.get("basecount"));*
*      *
*      }*
      public void reduce(Text key, Iterator<IntWritable> values,
OutputCollector<Text, IntWritable> output, Reporter reporter) throws
IOException {
        int sum =* baseSum*;
        while (values.hasNext()) {
          sum += values.next().get();
        output.collect(key, new IntWritable(sum));
And in main added:

So my hope was this should have done the trick..
But its not working. the code is running normally :(
How do i resolve this?