spark-TorrentBroadcastFactory.adoc

TorrentBroadcastFactory

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.

newBroadcast method creates a TorrentBroadcast (passing in the input value_ and id and ignoring the isLocal parameter).

Note	newBroadcast is executed when BroadcastManager is requested to create a new broadcast variable.

initialize and stop do nothing.

unbroadcast removes all the persisted state associated with a TorrentBroadcast of a given ID.