1. 創(chuàng)建SparkStreamingContext

   

   創(chuàng)新互聯(lián)的客戶(hù)來(lái)自各行各業(yè)，為了共同目標(biāo)，我們?cè)诠ぷ魃厦芮信浜希瑥膭?chuàng)業(yè)型小企業(yè)到企事業(yè)單位，感謝他們對(duì)我們的要求，感謝他們從不同領(lǐng)域給我們帶來(lái)的挑戰(zhàn)，讓我們激情的團(tuán)隊(duì)有機(jī)會(huì)用頭腦與智慧不斷的給客戶(hù)帶來(lái)驚喜。專(zhuān)業(yè)領(lǐng)域包括成都網(wǎng)站建設(shè)、網(wǎng)站制作、電商網(wǎng)站開(kāi)發(fā)、微信營(yíng)銷(xiāo)、系統(tǒng)平臺(tái)開(kāi)發(fā)。

   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))

                    //如果關(guān)閉的時(shí)候只想關(guān)閉StreamingContext不想關(guān)閉SparkContext則

                                sps.stop(false)