ElasticSearch-Hadoop API を使用しています。そして_mtermvector
、次のSparkコードを使用して取得しようとしていました:
val query= """_mtermvectors {
"ids" : ["1256"],
"parameters": {
"fields": [
"tname"
],
"term_statistics": true
}
}"""
var idRdd = sparkContext.esRDD("uindex/type1",query)
うまくいきませんでした。アイデアをお願いします。