¿Puedo convertir un RDD <POJO> en un Dataframe de forma que pueda escribir estos POJO en una tabla que tenga los mismos nombres de atributos que el POJO?

Según una respuesta hecha a Convertir Spark DataFrame a Pojo Object, he aprendido que a Dataframees un alias de Dataset<Row>.

He calculado actualmente JavaPairRDD<CityCode, CityStatistics>, donde CityStatisticses un POJO que contiene captadores y definidores de los miembros como: getCityCode(), getCityName(), getActivityCode(), getNumberOfSalaried(), getNumberOfCompanies()...

Un Liquibaseguión ha creado una tabla de estadísticas que (esos campos CITYCODE, CITYNAME, ACTIVITYCODE...) existen. Solo tengo que escribir los registros.

¿Cuál es (o antes de eso: hay alguna) forma limpia de hacer algo así desde mi JavaPairRDD<CityCode, CityStatistics> citiesStatisticsRDD?
citiesStatisticsRDD.values()=> DataSet<CityStatistics>=> DataSet<Row> (= DataFrame)=> escribir en una conexión JDBC a través de un método de marco de datos?

Gracias !

Respuesta 1

Estoy usando la API predeterminada java.util.Logging para imprimir información en mi registro. Logger.getLogger (Datastore.class.getName ()); logger.info ("Registro"); donde Datastore es el nombre de la clase, pero yo ...

He creado tres hilos en un programa de Java. Uno es el programa principal, los otros son dos clases que extienden Thread. El hilo principal representa un controlador para una máquina. Otro hilo es el ...

Los signos "&" en la url de los siguientes archivos xml arrojan errores al compilar en Android Studio. El error es que la línea 5-7 (línea url) en <DetailPageUrl> no está bien formada (no es válido ...

Estoy creando un juego de civilización para un proyecto solo preguntándome cuál es la mejor manera de hacerlo cuando se lee en un archivo .map con cada línea que tiene caracteres en su interior que representan un terrian, así que ...