Flink基礎概念&編程模型

Flink基礎概念&編程模型 Flink程序的基礎構建模塊是流(Streams)與轉換(transformations) 每一個數據流起始於一個或者多個source,並終止於一個或者多個sink 下面是一個由Flink程序映射爲Streaming Dataflow的示意圖 並行數據流示意圖 時間窗口: 流上的聚合需要由窗口來劃定範圍,比如,計算過去的5分鐘,或者最後100個元素的和 窗口通常被區分
相關文章
相關標籤/搜索