Class WatermarkWithIndex

  • All Implemented Interfaces:

    public final class WatermarkWithIndex
    extends java.lang.Object
    This contains a watermark and the src task index. It is used for transferring the watermark between tasks.
    See Also:
    Serialized Form
    • Constructor Detail

      • WatermarkWithIndex

        public WatermarkWithIndex​(Watermark watermark,
                                  int index)
    • Method Detail

      • getWatermark

        public Watermark getWatermark()
      • getIndex

        public int getIndex()
      • toString

        public java.lang.String toString()
        toString in class java.lang.Object