in flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events/kinesis/WatermarkEvent.java [24:26]
public WatermarkEvent() { this.watermark = DateTime.now(); }