Is this a duplicate with your Stackoverflow question?
http://stackoverflow.com/questions/34146800/convert-reducebykey-from-spark-to-flink
On Tue, Dec 8, 2015 at 2:25 PM, Humberto Moura <
humbe...@humbertomoura.com.br> wrote:
> Hello, guys
>
>
> I'm migrating a Spark code to Flink, and I realized
Hello, guys
I'm migrating a Spark code to Flink, and I realized that Spark
reduceByKey doesn't exist.
|the snip code I'm struggle: reduceByKey((x,y)=>(x._1
+y._1,((x._2)++y._2))) So, with a help of a friend I've tried convert: ||groupBy(0).reduce {(v1,v2)=>(v1._1 +v2._1,((v1._2)++v2._2))} bu
