private[eventhubs] def set[T]()

in core/src/main/scala/org/apache/spark/eventhubs/EventHubsConf.scala [66:82]

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

  private[eventhubs] def set[T](key: String, value: T): EventHubsConf = {
    if (key == null) {
      throw new NullPointerException("set: null key")
    }
    if (value == null) {
      throw new NullPointerException(s"set: null value for $key")
    }

    val lowerKey = key.toLowerCase

    if (self.get(lowerKey).isDefined && lowerKey != ConnectionStringKey.toLowerCase) {
      logWarning(s"$key has already been set to ${self.get(key).get}. Overwriting with $value")
    }

    settings.put(lowerKey, value.toString)
    this
  }