override def insert()

in spark-doris-connector/src/main/scala/org/apache/doris/spark/sql/DorisRelation.scala [92:104]

• 12 lines of code
• 4 McCabe index (conditional complexity)

  override def insert(data: DataFrame, overwrite: Boolean): Unit = {
    //replace 'doris.request.auth.user' with 'user' and 'doris.request.auth.password' with 'password'
    val insertCfg = cfg.copy().asProperties().asScala.map {
      case (ConfigurationOptions.DORIS_REQUEST_AUTH_USER, v) =>
        ("user", v)
      case (ConfigurationOptions.DORIS_REQUEST_AUTH_PASSWORD, v) =>
        ("password", v)
      case (k, v) => (k, v)
    }
    data.write.format(DorisSourceProvider.SHORT_NAME)
      .options(insertCfg)
      .save()
  }