//计算数量val res: DStream[Long] = value.countByWindow(Seconds(6), Seconds(6))
//计算数量
val res: DStream[Long] = value.countByWindow(Seconds(6), Seconds(6))
若有收获，就点个赞吧
0 人点赞
让时间为你证明
