Cómo agregar una nueva columna Struct a un DataFrame
Actualmente estoy tratando de extraer una base de datos de MongoDB y usar Spark para ingerir ElasticSearch congeo_points.
La base de datos de Mongo tiene valores de latitud y longitud, pero ElasticSearch requiere que se incluyan en elgeo_point tipo.
¿Hay alguna manera en Spark para copiar ellat ylon columnas a una nueva columna que es unarray ostruct?
Cualquier ayuda es apreciada!