org.apache.spark.broadcast
Interface BroadcastFactory

All Known Implementing Classes:

HttpBroadcastFactory, TorrentBroadcastFactory

public interface BroadcastFactory

:: DeveloperApi :: 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.

Method Summary

void	initialize(boolean isDriver, SparkConf conf, org.apache.spark.SecurityManager securityMgr)
<T> Broadcast<T>	newBroadcast(T value, boolean isLocal, long id, scala.reflect.ClassTag<T> evidence$1) Creates a new broadcast variable.
void	stop()
void	unbroadcast(long id, boolean removeFromDriver, boolean blocking)

Method Detail

initialize

void initialize(boolean isDriver,
                SparkConf conf,
                org.apache.spark.SecurityManager securityMgr)

newBroadcast

<T> Broadcast<T> newBroadcast(T value,
                              boolean isLocal,
                              long id,
                              scala.reflect.ClassTag<T> evidence$1)

Creates a new broadcast variable.

Parameters:

value - value to broadcast

isLocal - whether we are in local mode (single JVM process)

id - unique id representing this broadcast variable

evidence$1 - (undocumented)

Returns:

(undocumented)

unbroadcast

void unbroadcast(long id,
                 boolean removeFromDriver,
                 boolean blocking)

stop

void stop()