public Watermark checkAndGetNextWatermark()

in flink-taxi-stream-processor/src/main/java/com/amazonaws/flink/refarch/events/PunctuatedAssigner.java [36:38]

• 3 lines of code
• 2 McCabe index (conditional complexity)

  public Watermark checkAndGetNextWatermark(Event lastElement, long extractedTimestamp) {
    return lastElement instanceof WatermarkEvent ? new Watermark(extractedTimestamp) : null;
  }