hadoop-common-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Tom White <...@cloudera.com>
Subject Re: Problem with Counters
Date Thu, 05 Feb 2009 10:51:01 GMT
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 <speed.some@gmail.com> 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
>

Mime
View raw message