SparkStreaming——實例4：窗口操作

窗口函數，window 使用窗口長度和滑動間隔來計算，假設窗口長度爲3s，滑動間隔爲2s， 每2s窗口滑動一次，舊數據就只剩最後1s的了，丟棄左邊的2s數據， 右邊進入新的2s的數據，計算此時新的3秒鐘的數據。 滑動間隔默認等於批次間隔，如果要設置，滑動間隔必須是窗口間隔的整數倍。     代碼： 使用窗口函數： import org.apache.spark.{HashPartitioner,

>>阅读原文<<