def updatePerformancePercentage()

in core/src/main/scala/org/apache/spark/eventhubs/PartitionsStatusTracker.scala [399:406]

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

  def updatePerformancePercentage(averageTimePerEvent: Double, standardDeviation: Double): Unit = {
    val averagePlusStdDev: Double = averageTimePerEvent + standardDeviation
    if (!emptyBatch && hasBeenUpdated) {
      if (timePerEventInMillis > averagePlusStdDev) {
        performancePercentage = averageTimePerEvent / timePerEventInMillis
      }
    }
  }