Class WatermarkWithIndex

  • All Implemented Interfaces:
    java.io.Serializable

    public final class WatermarkWithIndex
    extends java.lang.Object
    implements java.io.Serializable
    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()
        Overrides:
        toString in class java.lang.Object