Class WatermarkWithIndex

  • All Implemented Interfaces:
    Serializable

    public final class WatermarkWithIndex
    extends Object
    implements 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()