Flink DataStream iterate算子的簡單使用

Flink DataStream iterate算子的簡單使用 因爲DataStream程序可能永遠不會完成，所以沒有最大迭代次數。相反你須要指定流的哪一個部分反饋到迭代，哪一個部分使用split轉換或轉發到下游filter。web 下面看示例：bootstrap public class IterateOperator { public static void main(String[]

>>阅读原文<<