drive端写入，val broadcastVar = sc.broadcast(Array(1, 2, 3))
－〉env.broadcastManager.newBroadcast[T](value, isLocal)
－〉TorrentBroadcastFactory：new TorrentBroadcast[T](value_, id)
在driver端的BlockManager中存储。
使用时调用：
broadcastVar.value broadcast仅是对value的包装，存储在driver/executors中，存储时可以指定racking(spark.storage.replication.topologyFile和spark.storage.replication.topologyMapper)，按spark.broadcast.blockSize（4M默认）分chunk存储，存储到本机、本rack、其它rack。
入口类BroadcastManager没有getValue或者value，只能在Driver中使用，如rdd.Map(_ ==broadcastVar.value)等
有遍文章不错：
网友评论