如何实施flink

Question

我需要在flink中使用foreach。是否有人可以展示有关如何在Flink中使用Map（）在Spark中实现foreach的示例？

Answer 1

使用map（）作为foreach（）的替换可能会起作用 - 您只需将foreach代码放入map（）中，然后在函数末尾返回原始元素。

如果您对" foreach"之后的数据流的内容不感兴趣，并且您只需要副作用，那么也许值得使用或实现水槽。例如，如果要求将数据插入数据库或消息系统或文件，则接收器可能是更好的选择。