特牛网址导航

Flink DataStream iterate算子的简单使用_flink iterate算子-CSDN博客

网友收藏
文章浏览阅读2.6k次,点赞3次,收藏2次。Flink DataStream iterate算子的简单使用由于DataStream程序可能永远不会完成,因此没有最大迭代次数。相反你需要指定流的哪个部分反馈到迭代,哪个部分使用split转换或转发到下游filter。下面看示例:public class IterateOperator { public static void main(String[] args) throws..._flink iterate算子