SparkStreaming——实例4：窗口操作

窗口函数，window 使用窗口长度和滑动间隔来计算，假设窗口长度为3s，滑动间隔为2s， 每2s窗口滑动一次，旧数据就只剩最后1s的了，丢弃左边的2s数据， 右边进入新的2s的数据，计算此时新的3秒钟的数据。 滑动间隔默认等于批次间隔，如果要设置，滑动间隔必须是窗口间隔的整数倍。     代码： 使用窗口函数： import org.apache.spark.{HashPartitioner,

>>阅读原文<<