Hi, Can someone help me with the usage of counters please? I am incrementing a counter in Reduce method but I am unable to collect the counter value after the job is completed.
Its something like this: public static class Reduce extends MapReduceBase implements Reducer<Text, FloatWritable, Text, FloatWritable> { static enum MyCounter{ct_key1}; public void reduce(..............) throws IOException { reporter.incrCounter(MyCounter.ct_key1, 1); output.collect(......); } } -----main method---- { RunningJob running = null; running=JobClient.runJob(conf); Counters ct = running.getCounters(); /********* How do I Collect the ct_key1 value ????***********/ long res = ct.getCounter(MyCounter.ct_key1); } Thanks, Sharath