override def flatMap1()

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

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

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