public class HttpBroadcast<T>
implements Logging, scala.Serializable
A Broadcast implementation that uses HTTP server
as a broadcast mechanism. The first time a HTTP broadcast variable (sent as part of a
task) is deserialized in the executor, the broadcasted data is fetched from the driver
(through a HTTP server running at the driver) and stored in the BlockManager of the
executor to speed up future accesses.
public static void unpersist(long id,
Remove all persisted blocks associated with this HTTP broadcast on the executors.
If removeFromDriver is true, also remove these persisted blocks on the driver
and delete the associated broadcast file.