网站介绍:文章浏览阅读1.2k次。一、共享变量可以节省内存与运行时间,提高并行处理的执行效率,共享变量包括:(1)Broadcast广播变量(2)accumulator累加器二、广播变量使用规则:1、可以使用SparkContext.broadcast([初始值])创建2、使用.value的方法读取广播变量的值3、广播变量被创建后,不可以被修改例如:val kvFruit = sc.parallelize(list((1,"app..._scala broadcast 广播变量 修改
- 链接地址:https://blog.csdn.net/weixin_41076809/article/details/79401994
- 链接标题:Broadcast广播变量_scala broadcast 广播变量 修改-CSDN博客
- 所属网站:blog.csdn.net
- 被收藏次数:7877
- 网站标签:scala broadcast 广播变量 修改