[spark streaming]窗口操作

WindowOperations（窗口操作）          Spark還提供了窗口的計算，它允許你使用一個滑動窗口應用在數據變換中。下圖說明了該滑動窗口。 如圖所示，每個時間窗口在一個個DStream中劃過，每個DSteam中的RDD進入Window中進行合併，操作時生成爲 窗口化DSteam的RDD。在上圖中，該操作被應用在過去的3個時間單位的數據，和劃過了2個時間單位。這說明任 何窗口操作

>>阅读原文<<