Soy relativamente nuevo en la programación de Spark y Java. Dado un archivo json con objetos anidados, necesito aplanar su estructura (desnormar el contenido) y cargarlo en Elastisearch usando chispa.

Por ejemplo,

si el contenido de mi ejemplo.json es:

 { "title": "Nest eggs", "body": "Making your money work...", "tags": [ "cash", "shares" ], "comments": { "name": "John Smith", "comment": "Great article", "age": 28, "stars": 4, "date": "2014-09-01" } "owner": { "name": "John Smith", "age": 28, } }

Me gustaría reconstruir esto en el siguiente formato y cargarlo en ES usando chispa.

 { "title": "Nest eggs", "body": "Making your money work...", "tags": [ "cash", "shares" ], "comments_name": "John Smith", "comments_comment": "Great article", "comments_age": 28 "comments_stars": 4, "comments_date": "2014-09-01" "owner_name": "John Smith", "owner_age": 28, }

En caso de que uno de los objetos anidados esté vacío, el contenido también se puede dejar vacío.

Cualquier ayuda es apreciada. Gracias