首页 > TAG信息列表 > ReduceBykeyAndWindow
DStream窗口操作-DStream_ReduceBykeyAndWindow
package org.hnsw import org.apache.spark.SparkConf import org.apache.spark.streaming.{Seconds, StreamingContext} object DStream_ReduceBykeyAndWindow { def main(args: Array[String]): Unit = { //1、初始化Context上下文 val conf = new SparkConf().set