Class StreamTransform<T>

  • Type Parameters:
    T - input/output type.
    All Implemented Interfaces:
    java.io.Serializable, Transform<T,​T>

    public final class StreamTransform<T>
    extends LatencymarkEmitTransform<T,​T>
    A Transform relays input data from upstream vertex to downstream vertex promptly. This transform can be used for merging input data into the OutputCollector.
    See Also:
    Serialized Form
    • Constructor Detail

      • StreamTransform

        public StreamTransform()
        Default constructor.
    • Method Detail

      • onData

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

        public void onWatermark​(Watermark watermark)
        Description copied from interface: Transform
        On watermark received. This method should be called for the minimum watermark among input streams (input watermark). Transform may emit collected data after receiving watermarks.
        Parameters:
        watermark - watermark
      • 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