我目前正在尝试从MongoDB中提取数据库,并使用Spark将其提取到ElasticSearch中geo_points.
geo_points
Mongo数据库具有纬度和经度值,但ElasticSearch要求将它们转换为geo_point类型.
geo_point
Spark中是否有一种方法可以将列lat和lon列复制到一个array或struct哪个新列？
lat
lon
array
struct
任何帮助表示赞赏!
etl scala elasticsearch apache-spark apache-spark-sql
apache-spark ×1
apache-spark-sql ×1
elasticsearch ×1
etl ×1
scala ×1