Class StreamTransform<T>

    • Constructor Detail

      • StreamTransform

        public StreamTransform()
        Default constructor.
    • Method Detail

      • onData

        public void onData​(T element)
        Description copied from interface: Transform
        On data received.
        Specified by:
        onData in interface Transform<T,​T>
        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.
        Specified by:
        onWatermark in interface Transform<T,​T>
        Parameters:
        watermark - watermark
      • close

        public void close()
        Description copied from interface: Transform
        Close the transform.
        Specified by:
        close in interface Transform<T,​T>