Según una respuesta hecha a Convertir Spark DataFrame a Pojo Object, he aprendido que a Dataframe
es un alias de Dataset<Row>
.
He calculado actualmente JavaPairRDD<CityCode, CityStatistics>
, donde CityStatistics
es un POJO que contiene captadores y definidores de los miembros como: getCityCode()
, getCityName()
, getActivityCode()
, getNumberOfSalaried()
, getNumberOfCompanies()
...
Un Liquibase
guió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 !
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 ...