public interface BroadcastFactory
Modifier and Type | Method and Description |
---|---|
void |
initialize(boolean isDriver,
SparkConf conf) |
<T> Broadcast<T> |
newBroadcast(T value,
boolean isLocal,
long id,
boolean serializedOnly,
scala.reflect.ClassTag<T> evidence$1)
Creates a new broadcast variable.
|
void |
stop() |
void |
unbroadcast(long id,
boolean removeFromDriver,
boolean blocking) |
void initialize(boolean isDriver, SparkConf conf)
<T> Broadcast<T> newBroadcast(T value, boolean isLocal, long id, boolean serializedOnly, scala.reflect.ClassTag<T> evidence$1)
value
- value to broadcastisLocal
- whether we are in local mode (single JVM process)id
- unique id representing this broadcast variableserializedOnly
- if true, do not cache the unserialized value on the driverevidence$1
- (undocumented)Broadcast
object, a read-only variable cached on each machinevoid stop()
void unbroadcast(long id, boolean removeFromDriver, boolean blocking)