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
URL网址:http://bzwzjz.com/article/pcjohh.html

其他资讯

Copyright © 2007-2020 广东宝晨空调科技有限公司 All Rights Reserved 粤ICP备2022107769号
友情链接: 响应式网站设计 成都网站设计 成都商城网站建设 成都网站制作 成都网站建设 网站建设公司 成都网站建设 成都企业网站设计 响应式网站设计 营销型网站建设 温江网站设计 成都网站建设 LED网站设计方案 成都网站建设公司 网站建设改版 企业网站设计 泸州网站建设 成都商城网站建设 自适应网站建设 响应式网站建设 成都网站设计 网站设计