Class: TorrentBroadcast

eclairjs/broadcast. TorrentBroadcast

A broadcast variable. Broadcast variables allow the programmer to keep a read-only variable cached on each machine rather than shipping a copy of it with tasks. They can be used, for example, to give every node a copy of a large input dataset in an efficient manner. Spark also attempts to distribute broadcast variables using efficient broadcast algorithms to reduce communication cost.

Constructor

new TorrentBroadcast()

Source:

Extends

Methods

destroy()

Destroy all data and metadata related to this broadcast variable. Use this with caution; once a broadcast variable has been destroyed, it cannot be used again. This method blocks until destroy has completed
Inherited From:
Source:

toString() → {string}

Inherited From:
Source:
Returns:
Type
string

unpersist(blockingopt)

Delete cached copies of this broadcast on the executors. If the broadcast is used after this is called, it will need to be re-sent to each executor.
Parameters:
Name Type Attributes Description
blocking boolean <optional>
 Whether to block until unpersisting has completed
Inherited From:
Source:

value() → {object}

Get the broadcasted value.
Inherited From:
Source:
Returns:
Type
object