def aadAuthCallback()

in core/src/main/scala/org/apache/spark/eventhubs/EventHubsConf.scala [627:647]

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

  def aadAuthCallback(): Option[AadAuthenticationCallback] = {
    val params: Map[String, Object] = self.get(AadAuthCallbackParamsKey) map EventHubsConf
      .read[Map[String, Object]] getOrElse Map.empty
    if (params.isEmpty) {
      self.get(AadAuthCallbackKey) map (className => {
        Class
          .forName(className)
          .getConstructor()
          .newInstance()
          .asInstanceOf[AadAuthenticationCallback]
      })
    } else {
      self.get(AadAuthCallbackKey) map (className => {
        Class
          .forName(className)
          .getConstructor(classOf[Map[String, Object]])
          .newInstance(params)
          .asInstanceOf[AadAuthenticationCallback]
      })
    }
  }