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(
  value_ : T,
  isLocal: Boolean,
  id: Long): Broadcast[T]

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

newBroadcast is part of the BroadcastFactory abstraction.

Deleting Broadcast Variable¶

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

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

unbroadcast is part of the BroadcastFactory abstraction.

Initializing¶

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

initialize does nothing (noop).

initialize is part of the BroadcastFactory abstraction.

Stopping¶

stop(): Unit

stop does nothing (noop).

stop is part of the BroadcastFactory abstraction.