天天看點

SparkStreamingContext

  1. 建立SparkStreamingContext

    1)val conf=new SparkConf().setMaster("local[2]").setAppName("wordcount")

      val streamContext=new StreamingContext(conf,Seconds(5))

繼續閱讀