TorrentBroadcastFactory

2014-11-15 分类：spark-core 阅读(1280) 评论(0)

TorrentBroadcastFactory is a BroadcastFactory of TorrentBroadcasts, i.e. BitTorrent-like broadcast variables.

Note	As of Spark 2.0 `TorrentBroadcastFactory` is the only implementation of BroadcastFactory.

initialize and stop do nothing.



newBroadcast[T: ClassTag](value_ : T, isLocal: Boolean, id: Long): Broadcast[T]

newBroadcast[T: ClassTag](value_ : T, isLocal: Boolean, id: Long): Broadcast[T]

Note	`newBroadcast` is part of BroadcastFactory Contract to…FIXME.

newBroadcast creates a TorrentBroadcast (for the input value_ and id and ignoring the isLocal parameter).

赞(0) 打赏

关注公众号：spark技术分享