override def onTimer()

in long-ride-alerts/src/solution/scala/org/apache/flink/training/solutions/longrides/scala/LongRidesSolution.scala [132:143]

• 8 lines of code
• 1 McCabe index (conditional complexity)

    override def onTimer(
        timestamp: Long,
        ctx: KeyedProcessFunction[Long, TaxiRide, Long]#OnTimerContext,
        out: Collector[Long]
    ): Unit = {

      // the timer only fires if the ride was too long
      out.collect(rideState.value().rideId)

      // clearing now prevents duplicate alerts, but will leak state if the END arrives
      rideState.clear()
    }