Broadcast广播变量_scala broadcast 广播变量 修改-CSDN博客

网站介绍:文章浏览阅读1.2k次。一、共享变量可以节省内存与运行时间,提高并行处理的执行效率,共享变量包括:(1)Broadcast广播变量(2)accumulator累加器二、广播变量使用规则:1、可以使用SparkContext.broadcast([初始值])创建2、使用.value的方法读取广播变量的值3、广播变量被创建后,不可以被修改例如:val kvFruit = sc.parallelize(list((1,"app..._scala broadcast 广播变量 修改