Class NoWatermarkEmitTransform<I,​O>

    • Constructor Detail

      • NoWatermarkEmitTransform

        public NoWatermarkEmitTransform()
    • Method Detail

      • onWatermark

        public final 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<I,​O>
        Parameters:
        watermark - watermark