spark08

spark08       這就是廣播變量，每個executor中複用一份數據，在driver端將數據廣播出去，在executor端使用 val bd = sc.broadcast(iparr) val proRDD = accRDD.map(t=>{   val province = binarySeach(t,bd.value)   (province,1) })   廣播變量的內部機制 比特

>>阅读原文<<