我正在尝试使用 scala elstic4s 客户端将新文档索引到我的弹性搜索集群中,但我遇到了类型的编译问题。按照在网络上找到的文档和示例,语法如下所示:
客户端实例化:
val settings = ImmutableSettings.settingsBuilder().put("cluster.name", Configuration.elasticsearchClusterName).build()
val uri = ElasticsearchClientUri("elasticsearch://" + Configuration.elasticsearchUri)
val client = ElasticClient.remote(settings, uri)
我试图这样写:
def writeToElasticsearch(bulkList: List[EventMessage]) {
val ops = for (message <- bulkList) yield index into indexDcp ttl 7.days.toMillis doc StringDocumentSource(message.toJSon())
client.execute(bulk(ops: _*)).await
}
我在批量操作中遇到编译错误:
Multiple markers at this line
- type mismatch; found : List[com.sksamuel.elastic4s.IndexDefinition] required:
Seq[Int]
谁能告诉我如何转换类型以使其工作?谢谢!