Spark 广播变量（broadcast）更新方法

Spark 广播变量（broadcast）更新方法 更新方法 spark 广播变量能够经过unpersist方法删除，而后从新广播 web val map = sc.textFile("/test.txt").map(line => { val arr = line.split(",") (arr(0), arr(2).toInt) }).distinct var mapBC =

>>阅读原文<<