从 Spark 向 Elasticsearch 插入地理数据

Question

我尝试在我的 ES 中上传一个带有纬度和经度字段的 RDD。我想使用 geo_point 类型将它们绘制在地图上。我试图为每个文档创建一个 "location" 字段，其中包含像“12.25，-5.2”这样的字符串或 lat/long 的两个双精度数组，但 ES 没有将它们检测为 geo_point .插入数据前索引不存在

如何告诉 ES 该位置是 geo_point？

要存储的带有 elasticsearch-hadoop 库的当前代码：

myRDD.saveToEs(indexName, someConf)

with myRDD 包含 "location" -> [double, double]

的 RDD[Map]

和someConf包含"es.index.auto.create" -> "true"

Answer 1

评论中建议的可行解决方案：

HTTP PUT 以创建仅映射此特定字段的索引
正常插入RDD

如果你在为时已晚之前插入了数据

从 Spark 向 Elasticsearch 插入地理数据

Insert geograpic data in Elastic Search from Spark

scala

elasticsearch

apache-spark

elasticsearch-hadoop