支持窗体化处理

目录

• • 1、window 输出窗口内容
    • 2、countByWindow 统计窗口中出现的元素个数
    • 3、countByValueAndWindow 统计具有相同值的元素数量
    • 4、reduceByWindow 对窗口内的数据执行归约操作并输出结果
    • 5、reduceByKeyAndWindow 在窗口内对键值对执行归约操作
    • 6、reduceByKeyAndWindow 对窗口内的流入与流出数据分别进行归约处理

所谓窗口函数，是指在DStream流中设定一个可调节长度的窗口，并以特定速率向前滑动该窗口。根据所应用的具体函数类型，对当前窗口内采集到的数据执行相应的计算操作。

需要特别指出的是，所设定的窗口长度以及滑动速率必须为批处理时间间隔的整数倍。

引入pom依赖项

    <dependency>
      <groupId>org.apache.kafka</groupId>
      <artifactId>kafka_2.11</artifactId>