SparkStreamingContext

1. 创建SparkStreamingContext
   

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

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

    2)val sps=new StreamingContext(new SparkContext(conf),Seconds(5))

                    //如果关闭的时候只想关闭StreamingContext不想关闭SparkContext则

                                sps.stop(false)

SparkStreamingContext

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