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