Class SingleInputWatermarkManager

  • All Implemented Interfaces:
    InputWatermarkManager

    public final class SingleInputWatermarkManager
    extends java.lang.Object
    implements InputWatermarkManager
    This is a special implementation for single input data stream for optimization.
    • Constructor Detail

      • SingleInputWatermarkManager

        public SingleInputWatermarkManager​(OutputCollector watermarkCollector)
    • Method Detail

      • trackAndEmitWatermarks

        public void trackAndEmitWatermarks​(int edgeIndex,
                                           Watermark watermark)
        This just forwards watermarks to the next operator because it has one data stream.
        Specified by:
        trackAndEmitWatermarks in interface InputWatermarkManager
        Parameters:
        edgeIndex - edge index
        watermark - watermark