apache-spark - 将DStream写入Elastic搜索时将字段编码为geo_point

Question

我正在写 JavaDStream
包含使用方法 JavaEsSparkStreaming.saveToEs 从 Spark 到 Elasticsearch 的Tweet类型的对象。以下是我的Tweet类的定义。

public class Tweet implements Serializable{

String longitude;
String latitude;
String sentiment;
String text;
String post_date;
String geo_point;

在geo_point中，我要附加经度，纬度。

当我将此DStream写入ES时，字段geo_point的类型显示为文本，并且无法在Kibana上使用它来可视化“地理 map ”上的数据。我已经设置了es.index.auto.create = true。如何将该字段的类型转换为geo_point以便可以在Kibana Map上使用？

Answer 1

现在解决了。使用Java代码在ES中转储数据之前创建索引，并将字段类型标记为geo_point。然后开始在ES中转储数据。现在，我可以将该字段用于 map ，因为类型为geo_point。