context.getCounter() in Flink

Posted by Hung on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/context-getCounter-in-Flink-tp585.html

Hi,

Could I ask how to give surrogate key for the output of mapreduce?
ex.
a OX
b XO
c XX

becomes

1 a OX
2 b XO
3 C XX

By calling context.getCounter() and .increment(1) can achieve the above task.
How to achieve that in Flink?
I found the following Flink API document but don't know how `value` can call getCounter()
https://flink.incubator.apache.org/docs/0.6-incubating/api/java/org/apache/flink/hadoopcompatibility/mapred/wrapper/HadoopDummyReporter.html