Hi Sharath, The code you posted looks right to me. Counters#getCounter() will return the counter's value. What error are you getting?
Tom On Thu, Feb 5, 2009 at 10:09 AM, some speed <[email protected]> wrote: > 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 >
