private def sendPartitionPerformanceToDriver()

in core/src/main/scala/org/apache/spark/eventhubs/client/CachedEventHubsReceiver.scala [336:348]

• 13 lines of code
• 3 McCabe index (conditional complexity)

  private def sendPartitionPerformanceToDriver(partitionPerformance: PartitionPerformanceMetric) = {
    logDebug(
      s"(Task: ${EventHubsUtils.getTaskContextSlim}) sends PartitionPerformanceMetric: " +
        s"${partitionPerformance} to the driver.")
    try {
      CachedEventHubsReceiver.partitionPerformanceReceiverRef.send(partitionPerformance)
    } catch {
      case e: Exception =>
        logError(
          s"(Task: ${EventHubsUtils.getTaskContextSlim}) failed to send the RPC message containing " +
            s"PartitionPerformanceMetric: ${partitionPerformance} to the driver with error: ${e}.")
    }
  }