org.apache.spark.broadcast

Class BroadcastManager

Object

org.apache.spark.broadcast.BroadcastManager

All Implemented Interfaces:

Logging

public class BroadcastManager
extends Object
implements Logging

Constructor Summary

Constructors

Constructor and Description
BroadcastManager(boolean isDriver, SparkConf conf, SecurityManager securityManager)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	isDriver()
<T> Broadcast<T>	newBroadcast(T value_, boolean isLocal, scala.reflect.ClassTag<T> evidence$1)
void	stop()
void	unbroadcast(long id, boolean removeFromDriver, boolean blocking)

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.spark.Logging

initializeIfNecessary, initializeLogging, isTraceEnabled, log_, log, logDebug, logDebug, logError, logError, logInfo, logInfo, logName, logTrace, logTrace, logWarning, logWarning

Constructor Detail

BroadcastManager

public BroadcastManager(boolean isDriver,
                SparkConf conf,
                SecurityManager securityManager)

Method Detail

isDriver

public boolean isDriver()

stop

public void stop()

newBroadcast

public <T> Broadcast<T> newBroadcast(T value_,
                            boolean isLocal,
                            scala.reflect.ClassTag<T> evidence$1)

unbroadcast

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