如何通過使用Elasticsearch Hadoop獲得術語向量

Question

我正在使用ElasticSearch-Hadoop API。我試圖通過使用以下星火代碼獲取_mtermvector：

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

它沒有工作，任何想法請欣賞！

Answer 1

您不能使用屬於帶有ES-Hadoop的document API's的端點（如_mtermvectors）。只允許查詢屬於query API's，query DSL或external resource。

希望它有幫助。