Class MessageGeneratorTransform<I,​K,​V>

  • Type Parameters:
    I - input type.
    K - output key type.
    V - output value type.
    All Implemented Interfaces:
    java.io.Serializable, Transform<I,​Pair<K,​V>>

    public final class MessageGeneratorTransform<I,​K,​V>
    extends NoWatermarkEmitTransform<I,​Pair<K,​V>>
    A Transform for the message generator vertex.
    See Also:
    Serialized Form
    • Method Detail

      • onData

        public void onData​(I element)
        Description copied from interface: Transform
        On data received.
        Parameters:
        element - data received.
      • close

        public void close()
        Description copied from interface: Transform
        Close the transform.
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object