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

Reply via email to