spark08

spark08       这就是广播变量，每个executor中复用一份数据，在driver端将数据广播出去，在executor端使用 val bd = sc.broadcast(iparr) val proRDD = accRDD.map(t=>{   val province = binarySeach(t,bd.value)   (province,1) })   广播变量的内部机制 比特

>>阅读原文<<