Interface Transform<I,​O>

    • Method Detail

      • prepare

        void prepare​(Transform.Context context,
                     OutputCollector<O> outputCollector)
        Prepare the transform.
        context - of the transform.
        outputCollector - that collects outputs.
      • onData

        void onData​(I element)
        On data received.
        element - data received.
      • onWatermark

        void onWatermark​(Watermark watermark)
        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.
        watermark - watermark
      • close

        void close()
        Close the transform.