如何在flink中实现foreach?


0

我需要在flink中使用foreach。

1 答案


0

使用map()作为foreach()的替代品应该是可行的——您只需将foreach代码放在map()中,然后在函数末尾返回原始元素。

如果您对“foreach”之后的数据流内容不感兴趣,并且只需要副作用,那么使用或实现sink可能是值得的。例如,如果需要将数据插入数据库、消息传递系统或文件中,sink可能是更好的选择。


我来回答

写文章

提问题

面试题