importorg.apache.spark.SparkConfimportorg.apache.spark.streaming.Secondsimportorg.apache.spark.streaming.StreamingContextobjectWordCountextendsApp{valconf=newSparkConf().setMaster("local[2]").setAppName("wordcount")valstreamContext=newStreamingContext(conf,..
分类：
其他好文 时间：
2017-03-10 11:23:15
阅读次数：
169
