TorrentBroadcastFactory¶

TorrentBroadcastFactory is a BroadcastFactory of TorrentBroadcasts.

Creating Instance¶

TorrentBroadcastFactory takes no arguments to be created.

TorrentBroadcastFactory is created for BroadcastManager.

Creating Broadcast Variable¶

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

newBroadcast creates a new TorrentBroadcast with the given value_ and id (and ignoring isLocal).

Deleting Broadcast Variable¶

unbroadcast(
  id: Long,
  removeFromDriver: Boolean,
  blocking: Boolean): Unit

unbroadcast removes all persisted state associated with the broadcast variable (identified by id).

Initializing¶

initialize(
  isDriver: Boolean,
  conf: SparkConf): Unit

initialize does nothing (noop).

Stopping¶

stop(): Unit

stop does nothing (noop).