小编Hum*_*ura的帖子

如何将此示例 scala spark 代码转换为 apache flink？

reduceByKey( (x, y) => (x._1 + y._1, ( (x._2) ++ y._2) ) )

我意识到reduceByKeyflink 中不存在，但它显示了我想要实现的目标。

谢谢任何帮助！