可以设置窗口的大小和滑动的步长来动态的获取当前Steaming的允许状态
    根据Steaming的批次处理，将前面批次的数据和当前数据进行整合

    如果每批次的时间是3秒，那么该函数的作用是将2批次的数据可以进行统一处理

    1. val windows: DStream[(String, Int)] = value.window(Seconds(6))

    image.png

    如果按照上面的方式做的话会造成有重复数据所以需要步长，要解决这一问题 

    1. val windows: DStream[(String, Int)] = value.window(Seconds(6),Seconds(6))

    image.png
    ⚠️：每次滑动将会触发计算