override def open()

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

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

    override def open(parameters: Configuration): Unit = {
      rideState = getRuntimeContext.getState(
        new ValueStateDescriptor[TaxiRide]("ride event", classOf[TaxiRide])
      )
    }