步长是3秒，那么每次滑动就会有6秒是重复数据，会减去之前这6秒的数据 //消除重复val res: DStream[(String, Int)] = value.reduceByKeyAndWindow( _ + _, _ - _, Seconds(9), Seconds(3))
