DStream操作之Window Operations(開窗函數)

什麼是DStream Discretized Stream是Spark Streaming的基礎抽象,代表持續性的數據流和經過各種Spark算子操作後的結果數據流。在內部實現上,DStream是一系列連續的RDD來表示。每個RDD含有一段時間間隔內的數據,如下圖: 對數據的操作也是按照RDD爲單位來進行的 Spark Streaming使用數據源產生的數據流創建DStream,也可以在 已有的DS
相關文章
相關標籤/搜索