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.

results matching ""

    No results matching ""