private def closeInner()

in core/src/main/scala/org/apache/spark/sql/eventhubs/EventHubsForeachWriter.scala [77:98]

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

  private def closeInner(isSuccess: Boolean): Unit = {
    var success = false
    if (client != null) {
      try {
        client.close()
        success = true
      } catch {
        case e: Exception =>
          log.warn(s"an error occurred. eventhub name = ${ehConf.name}, error = ${e.getMessage}")
          throw e
      }
      client = null
    }

    metricPlugin.foreach(
      _.onSendMetric(EventHubsUtils.getTaskContextSlim,
                     ehConf.name,
                     totalMessageCount,
                     totalMessageSizeInBytes,
                     System.currentTimeMillis() - writerOpenTime,
                     isSuccess && success))
  }