/
NikolayIvkin
/
tutorials1
Обзор
Документация
Войти
/
NikolayIvkin
/
tutorials1
Код
Запросы
0
Пакеты
0
Релизы
0
Аналитика
Безопасность
master
apache-spark/src/main/java/com/baeldung/dataframes/DataFrameToCustomerConverterApp.java
21 строка
705 B
ukhan1980
[BAEL-3634] Code for Spark DataFrame article (#12039)
03 май 2022, 22:47
03 май 2022, 22:47
728b3c9
Код
Авторство
О чём код?
package com.baeldung.dataframes; import org.apache.spark.sql.Dataset; import org.apache.spark.sql.Encoders; import org.apache.spark.sql.Row; public class DataFrameToCustomerConverterApp { public static void main(String[] args) { Dataset<Row> df = SparkDriver.getSparkSession() .read() .format("org.apache.spark.sql.execution.datasources.json.JsonFileFormat") .option("multiline", true) .load("data/minCustomerData.json"); df.show(); df.printSchema(); Dataset<Customer> customerDS = df.map(new RowToCustomerMapper(), Encoders.bean(Customer. class)); customerDS.show(); customerDS.printSchema(); } }