Package org.apache.nemo.runtime.executor
Class TransformContextImpl
- java.lang.Object
-
- org.apache.nemo.runtime.executor.TransformContextImpl
-
- All Implemented Interfaces:
java.io.Serializable
,Transform.Context
public final class TransformContextImpl extends java.lang.Object implements Transform.Context
Transform Context Implementation.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description TransformContextImpl(BroadcastManagerWorker broadcastManagerWorker)
Constructor of Context Implementation.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.Object
getBroadcastVariable(java.io.Serializable tag)
java.util.Optional<java.lang.String>
getSerializedData()
Retrieve the serialized data on the executor.void
setSerializedData(java.lang.String serializedData)
Put serialized data to send to the executor.
-
-
-
Constructor Detail
-
TransformContextImpl
public TransformContextImpl(BroadcastManagerWorker broadcastManagerWorker)
Constructor of Context Implementation.- Parameters:
broadcastManagerWorker
- for broadcast variables.
-
-
Method Detail
-
getBroadcastVariable
public java.lang.Object getBroadcastVariable(java.io.Serializable tag)
- Specified by:
getBroadcastVariable
in interfaceTransform.Context
- Parameters:
tag
- of the variable to get.- Returns:
- the broadcast variable.
-
setSerializedData
public void setSerializedData(java.lang.String serializedData)
Description copied from interface:Transform.Context
Put serialized data to send to the executor.- Specified by:
setSerializedData
in interfaceTransform.Context
- Parameters:
serializedData
- the serialized data.
-
getSerializedData
public java.util.Optional<java.lang.String> getSerializedData()
Description copied from interface:Transform.Context
Retrieve the serialized data on the executor.- Specified by:
getSerializedData
in interfaceTransform.Context
- Returns:
- the serialized data.
-
-