core/src/main/scala/spark/broadcast/BroadcastFactory.scala


1
2
3
4
5
6
7
8
9
10
11
12
13

package spark.broadcast

/**
 * An interface for all the broadcast implementations in Spark (to allow 
 * multiple broadcast implementations). SparkContext uses a user-specified
 * BroadcastFactory implementation to instantiate a particular broadcast for the
 * entire Spark job.
 */
private[spark] trait BroadcastFactory {
  def initialize(isDriver: Boolean): Unit
  def newBroadcast[T](value: T, isLocal: Boolean, id: Long): Broadcast[T]
  def stop(): Unit
}