BroadcastFactory¶

BroadcastFactory is an abstraction of broadcast variable factories that BroadcastManager uses to create or delete broadcast variables.

Contract¶

Initializing¶

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

Used when:

• BroadcastManager is requested to initialize

Creating Broadcast Variable¶

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

Used when:

• BroadcastManager is requested for a new broadcast variable

Stopping¶

stop(): Unit

Used when:

• BroadcastManager is requested to stop

Deleting Broadcast Variable¶

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

Used when:

• BroadcastManager is requested to delete a broadcast variable

Implementations¶

• TorrentBroadcastFactory