Interface WatermarkManager


  • @Experimental
    public interface WatermarkManager
    The WatermarkManager interface provides a mechanism to emit watermarks from a process function.
    • Method Detail

      • emitWatermark

        void emitWatermark​(Watermark watermark)
        Emits a watermark from the process function.
        Parameters:
        watermark - the Watermark to emit.