Class SingleInputWatermarkManager

    • 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