override def flatMap2()

in rides-and-fares/src/solution/scala/org/apache/flink/training/solutions/ridesandfares/scala/RidesAndFaresSolution.scala [104:112]

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

    override def flatMap2(fare: TaxiFare, out: Collector[RideAndFare]): Unit = {
      val ride = rideState.value
      if (ride != null) {
        rideState.clear()
        out.collect(new RideAndFare(ride, fare))
      } else {
        fareState.update(fare)
      }
    }