window

WindowDaemon App{
      =SparkConf().setMaster().setAppName()
      =StreamingContext(,())
      =.socketTextStream(,)
      .flatMap(_.split()).map((_,)).reduceByKeyAndWindow((v1:Int,v2:Int)=>{v1+v2},(),())
       .print()
       .start()
       .awaitTermination()
}

window

原文：http://11194009.blog.51cto.com/11184009/1905384