Spark2.2 广播变量broadcast原理及源码剖析

实例 首先先来看一看broadcast的使用代码:java val factor = List[Int](1,2,3); val factorBroadcast = sc.broadcast(factor) val nums = Array(1,2,3,4,5,6,7,8,9) val numsRdd = sc.parallelize(nums,3) val l
相关文章
相关标签/搜索