Mailing-List: contact mapreduce-user-help@hadoop.apache.org; run by ezmlm
Precedence: bulk
Reply-To: mapreduce-user@hadoop.apache.org
Received-SPF: pass (nike.apache.org: domain of mapred.learn@gmail.com
 designates 209.85.215.176 as permitted sender)
MIME-Version: 1.0
In-Reply-To: <12f3b19a.2dc52.133f3d4e30e.Coremail.rabbit_cheng@126.com>
References: <12f3b19a.2dc52.133f3d4e30e.Coremail.rabbit_cheng@126.com>
Date: Thu, 1 Dec 2011 11:05:04 -0800
Message-ID: 
 <CAFxxKidQ_pjhPUMOUUnfYJiUvwTXfbJ19kwSutdMX7zfLOi3Hw@mail.gmail.com>
Subject: Re: how to access a mapper counter in reducer
From: Mapred Learn <mapred.learn@gmail.com>
To: mapreduce-user@hadoop.apache.org, rabbit_cheng@126.com
Content-Type: multipart/alternative; boundary=0016e6daa93ab50f4804b30c8726

--0016e6daa93ab50f4804b30c8726
Content-Type: text/plain; charset=ISO-8859-1

Hi,
I have a similar query.

Infact, I sent it yesterday and waiting for anybody's response who might
have done it.


Thanks,
Anurag Tangri

2011/11/30 rabbit_cheng <rabbit_cheng@126.com>

>  I have created a counter in mapper to count something, I wanna get the
> counter's value in reducer phase, the code segment is as follow:
>
> public class MM extends Mapper<LongWritable, Text, Text, Text> {
>     static enum TEST{ pt }
>     @Override
>     public void map(LongWritable key, Text values, Context context) throws
> IOException, InterruptedException {
>         context.getCounter(TEST.pt).increment(1);
>     }
> }
> public class KMeansReducer extends Reducer<Text, Text, Text, Text> {
>     @Override
>     protected void setup(Context context) throws IOException,
> InterruptedException {
>         long ptValue=context.getCounter(MM.TEST.pt <http://mm.test.pt/>
> ).getValue();
>     }
> }
> but what I get is always 0, i.e., the value of variable ptValue is always
> 0.
> Does anybody know how to access a mapper counter in reducer?
>
>
>
>

--0016e6daa93ab50f4804b30c8726
Content-Type: text/html; charset=ISO-8859-1
Content-Transfer-Encoding: quoted-printable

<div>Hi,</div>
<div>I have a similar query.</div>
<div>=A0</div>
<div>Infact, I sent it yesterday and waiting for anybody&#39;s response who=
 might have done it.</div>
<div>=A0</div>
<div>=A0</div>
<div>Thanks,</div>
<div>Anurag Tangri<br><br></div>
<div class=3D"gmail_quote">2011/11/30 rabbit_cheng <span dir=3D"ltr">&lt;<a=
 href=3D"mailto:rabbit_cheng@126.com">rabbit_cheng@126.com</a>&gt;</span><b=
r>
<blockquote style=3D"BORDER-LEFT: #ccc 1px solid; MARGIN: 0px 0px 0px 0.8ex=
; PADDING-LEFT: 1ex" class=3D"gmail_quote">
<div style=3D"LINE-HEIGHT: 1.7; FONT-FAMILY: arial; COLOR: #000000; FONT-SI=
ZE: 14px">=A0I have created a counter in mapper to count something, I wanna=
 get the counter&#39;s value in reducer phase, the code segment is as follo=
w:<br>
<br>public class MM extends Mapper&lt;LongWritable, Text, Text, Text&gt; {<=
br>=A0=A0=A0 static enum TEST{ pt }<br>=A0=A0=A0 @Override<br>=A0=A0=A0 pub=
lic void map(LongWritable key, Text values, Context context) throws IOExcep=
tion, InterruptedException {<br>
=A0=A0=A0 =A0=A0=A0 context.getCounter(TEST.pt).increment(1);<br>=A0=A0=A0 =
}<br>}<br>public class KMeansReducer extends Reducer&lt;Text, Text, Text, T=
ext&gt; {<br>=A0=A0=A0 @Override<br>=A0=A0=A0 protected void setup(Context =
context) throws IOException,=A0 InterruptedException {<br>
=A0=A0=A0 =A0=A0=A0 long ptValue=3Dcontext.getCounter(<a href=3D"http://mm.=
test.pt/" target=3D"_blank">MM.TEST.pt</a>).getValue();<br>=A0=A0=A0 }<br>}=
<br>but what I get is always 0, i.e., the value of variable ptValue is alwa=
ys 0. <br>Does anybody know how to access a mapper counter in reducer?<br>
<br></div><br><br><span title=3D"neteasefooter"><span></span></span></block=
quote></div><br>

--0016e6daa93ab50f4804b30c8726--