Mailing-List: contact user-help@flink.apache.org; run by ezmlm
Precedence: bulk
MIME-Version: 1.0
From: Julio Biason <julio.biason@azion.com>
Date: Thu, 14 Dec 2017 10:56:41 -0200
Message-ID: <CAEM7gE2uowbFKG9UuvG4X_dB4RxDfZgDga8ZwBsq=LAAuCi3Hg@mail.gmail.com>
Subject: [Docs] Can't add metrics to RichFilterFunction
To: User <user@flink.apache.org>
Content-Type: multipart/alternative; boundary="94eb2c116ea85d0a6505604c6afa"
archived-at: Thu, 14 Dec 2017 12:56:46 -0000

--94eb2c116ea85d0a6505604c6afa
Content-Type: text/plain; charset="UTF-8"

Hello,

I'm trying to add a metric to a filter function, but following the example
in the docs is not working.

So I have this class:

```
class LogBrokenFilter extends RichFilterFunction[LineData] {
  private val logger = LoggerFactory.getLogger(this.getClass)
  @transient private var counter:Counter

  override def open(parameters:Configuration):Unit = {
    counter = getRuntimeContext
      .getMetricGroup()
      .counter("brokenLogs")
  }

  // and then I override `filter` to do filter events out and count those.
```

The problem is that, when compiling, I get the following errors:

abstract member may not have private modifier
[error]   @transient private var counter:Counter

and

no valid targets for annotation on method counter - it is discarded unused.
You may specify targets with meta-annotations, e.g. @(transient @getter)
[warn]   @transient private var counter:Counter
[warn]    ^

Any ideas? Are the docs wrong?

-- 
*Julio Biason*, Sofware Engineer
*AZION*  |  Deliver. Accelerate. Protect.
Office: +55 51 3083 8101 <callto:+555130838101>  |  Mobile: +55 51
<callto:+5551996209291>*99907 0554*

--94eb2c116ea85d0a6505604c6afa
Content-Type: text/html; charset="UTF-8"
Content-Transfer-Encoding: quoted-printable

<div dir=3D"ltr"><div><div><div>Hello,<br><br></div>I&#39;m trying to add a=
 metric to a filter function, but following the example in the docs is not =
working.<br><br></div>So I have this class:<br><br>```<br>class LogBrokenFi=
lter extends RichFilterFunction[LineData] {<br>=C2=A0 private val logger =
=3D LoggerFactory.getLogger(this.getClass)<br>=C2=A0 @transient private var=
 counter:Counter<br><br>=C2=A0 override def open(parameters:Configuration):=
Unit =3D {<br>=C2=A0=C2=A0=C2=A0 counter =3D getRuntimeContext<br>=C2=A0=C2=
=A0=C2=A0=C2=A0=C2=A0 .getMetricGroup()<br>=C2=A0=C2=A0=C2=A0=C2=A0=C2=A0 .=
counter(&quot;brokenLogs&quot;)<br>=C2=A0 }<br><br></div>=C2=A0 // and then=
 I override `filter` to do filter events out and count those.<br><div><div>=
```</div><div><br></div><div>The problem is that, when compiling, I get the=
 following errors:</div><div><br></div><div>abstract member may not have pr=
ivate modifier<br>[error]=C2=A0=C2=A0 @transient private var counter:Counte=
r</div><div><br></div><div>and</div><div><br></div><div>no valid targets fo=
r annotation on method counter - it is discarded unused. You may specify ta=
rgets with meta-annotations, e.g. @(transient @getter)<br>[warn]=C2=A0=C2=
=A0 @transient private var counter:Counter<br>[warn]=C2=A0=C2=A0=C2=A0 ^</d=
iv><div><br></div><div>Any ideas? Are the docs wrong?<br></div><div><div><d=
iv><div><br>-- <br><div class=3D"gmail_signature"><div dir=3D"ltr"><div><fo=
nt color=3D"#000000"><span style=3D"font-family:arial,helvetica,sans-serif"=
><b>Julio Biason</b></span><span style=3D"font-family:arial,helvetica,sans-=
serif">,</span></font><span style=3D"color:rgb(119,119,119);font-family:ari=
al,helvetica,sans-serif"> Sofware Engineer<br></span></div><div style=3D"co=
lor:rgb(136,136,136);font-family:arial,helvetica,sans-serif;margin:0.25em 0=
px"><b style=3D"color:rgb(239,101,47);font-family:Arial,Helvetica,sans-seri=
f">AZION</b><span style=3D"font-family:Arial,Helvetica,sans-serif;color:rgb=
(239,101,47)">=C2=A0 | =C2=A0</span><span style=3D"color:rgb(239,101,47);fo=
nt-family:Arial,Helvetica,sans-serif">Deliver. Accelerate. Protect.</span><=
/div><span style=3D"font-size:12.8px;font-family:Calibri,sans-serif;color:r=
gb(0,0,0)"><div dir=3D"ltr"><div style=3D"font-family:Helvetica"><div style=
=3D"margin:0.25em 0px;font-family:Arial,Helvetica,sans-serif"><div style=3D=
"margin:0.25em 0px">Office:=C2=A0<a href=3D"callto:+555130838101" value=3D"=
+555130838101" style=3D"color:rgb(17,85,204);font-family:arial,sans-serif;f=
ont-size:12.8px" target=3D"_blank">+55 51 3083 8101</a>=C2=A0 | =C2=A0Mobil=
e:=C2=A0<font style=3D"color:rgb(17,85,204)" color=3D"#1155cc"><a href=3D"c=
allto:+5551996209291" style=3D"color:rgb(17,85,204)" target=3D"_blank">+55 =
51=C2=A0</a><u>99907 0554</u></font></div></div></div></div></span></div></=
div>
</div></div></div></div></div></div>

--94eb2c116ea85d0a6505604c6afa--