public long getTimestamp() {
    return timestamp;
  }
The WatermarkMessage is a control message that is sent out to next stage
 with a watermark timestamp and the task that produces the watermark.
samza-api/src/main/java/org/apache/samza/system/WatermarkMessage.java