Package org.apache.nemo.runtime.executor.data

Class BroadcastManagerWorker

java.lang.Object

org.apache.nemo.runtime.executor.data.BroadcastManagerWorker

@ThreadSafe
public final class BroadcastManagerWorker
extends java.lang.Object

Used by tasks to get/fetch (probably remote) broadcast variables.

Method Summary

Modifier and Type	Method	Description
java.lang.Object	get(java.io.Serializable id)	Get the variable with the id.
static BroadcastManagerWorker	getStaticReference()

Methods inherited from class java.lang.Object

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

Method Detail

get

public java.lang.Object get(java.io.Serializable id)

Get the variable with the id.

Parameters:

id - of the variable.

Returns:

the variable.

getStaticReference

public static BroadcastManagerWorker getStaticReference()

Returns:

the static reference for those that do not use TANG and cannot access the singleton object.