spark中的广播变量broadcast

Spark中的Broadcast处理 首先先来看一看broadcast的使用代码:app val values = List[Int](1,2,3)dom val broadcastValues = sparkContext.broadcast(values)ide rdd.mapPartitions(iter => {函数   broadcastValues.getValue.foreach(p

>>阅读原文<<