使用脚本调用ElasticSearch API时Scala Map不兼容问题求助

你在Scala里调用Elasticsearch带脚本的Update API时遇到的编译错误，核心是Scala Map转Java Map的方式不对，我来帮你搞定这个问题：

问题根源 #

你用的mapAsJavaMap(params)调用方式不符合JavaConverters的使用逻辑——JavaConverters提供的是隐式扩展方法，不是直接调用的工具方法。另外，Scala 2.13+版本更推荐用scala.jdk.CollectionConverters替代旧的JavaConverters，后者已经逐步被弃用。

修正后的代码方案 #

下面是调整后的代码，我标注了关键修改点：

import org.elasticsearch.action.update.UpdateRequest
import org.elasticsearch.client.RequestOptions
import org.elasticsearch.script.{Script, ScriptType}
// 推荐使用Scala 2.13+的CollectionConverters，替代旧的JavaConverters
import scala.jdk.CollectionConverters._

object Testing extends App {
  val result = updateByScript("testing", "hW7BBnQBn2nWmIjS_b0C", 10.0)
  println("@@@@@@result:---> " + result)
  high_level_client.close()

  def updateByScript(index: String, id: String, count: Double) = {
    val updateRequest = new UpdateRequest(index, id)
    // Scala Map定义保持不变
    val params = Map[String, Double]("count" -> count)
    // 使用asJava方法将Scala Map转为Java Map，隐式来自CollectionConverters
    val script = new Script(
      ScriptType.INLINE,
      "painless",
      "ctx._source.count += params.count",
      params.asJava // 关键修改：替换mapAsJavaMap(params)为params.asJava
    )
    updateRequest.script(script)
    high_level_client.update(updateRequest, RequestOptions.DEFAULT)
  }
}

额外说明 #

• 如果你的项目还在使用Scala 2.12及以下版本，继续用import scala.collection.JavaConverters._也没问题，同样用params.asJava转换即可，不需要直接调用mapAsJavaMap方法。
• 关于泛型匹配：Elasticsearch的Script构造器要求java.util.Map<String, Object>，Scala的Map<String, Double>转成Java Map后会自动适配为Map<String, Object>，因为Double是Object的子类，编译器会自动处理向上转型，不需要额外操作。

这样修改后就能解决编译错误，顺利执行脚本更新操作了。

内容的提问来源于stack exchange，提问作者Keshav Lodhi