scala - 如何使用 Elasticsearch Hadoop 获取术语向量

Question

我正在使用 ElasticSearch-Hadoop API。我试图_mtermvector通过使用以下 Spark 代码来获得：

val query= """_mtermvectors {
        "ids" : ["1256"],
        "parameters": {
            "fields": [
                 "tname"
            ],
            "term_statistics": true
        }
}"""
var idRdd = sparkContext.esRDD("uindex/type1",query)

没用，请大家多多指教，不胜感激！

Answer 1

您不能在ES-Hadoop 中使用属于文档 API一部分的端点（如 _mtermvectors）。只允许属于查询 API、查询 DSL或外部资源的查询。

希望它有所帮助。