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