def close()

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

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

  def close(errorOrNull: Throwable): Unit = {
    log.info(s"close is called. ${EventHubsUtils.getTaskContextSlim}")

    errorOrNull match {
      case t: Throwable =>
        log.warn(s"an error occurred. eventhub name = ${ehConf.name}, error = ${t.getMessage}")
        closeInner(false)
        throw t
      case _ => closeInner(true)
    }
  }