Flink DataStream iterate算子的簡單使用

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