Package org.apache.nemo.common.ir.vertex.transform

Interface Transform.Context

  • All Superinterfaces:
    java.io.Serializable
    All Known Implementing Classes:
    TransformContextImpl
    Enclosing interface:
    Transform<I,​O>
    public static interface Transform.Context
extends java.io.Serializable
    Context of the transform.

    • Method Detail

      • getBroadcastVariable

        java.lang.Object getBroadcastVariable​(java.io.Serializable id)
        Parameters:
        id - of the variable to get.
        Returns:
        the broadcast variable.

      • setSerializedData

        void setSerializedData​(java.lang.String serializedData)
        Put serialized data to send to the executor.
        Parameters:
        serializedData - the serialized data.

      • getSerializedData

        java.util.Optional<java.lang.String> getSerializedData()
        Retrieve the serialized data on the executor.
        Returns:
        the serialized data.