/
NikolayIvkin
/
tutorials1
Обзор
Документация
Войти
/
NikolayIvkin
/
tutorials1
Код
Запросы
0
Пакеты
0
Релизы
0
Аналитика
Безопасность
master
apache-spark/src/main/java/com/baeldung/dataframes/CustomerToRowMapper.java
18 строк
574 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.commons.lang3.StringUtils; import org.apache.spark.api.java.function.MapFunction; import org.apache.spark.sql.Row; import org.apache.spark.sql.RowFactory; public class CustomerToRowMapper implements MapFunction<Customer, Row> { @Override public Row call(Customer customer) { Row row = RowFactory.create( customer.getId(), customer.getName().toUpperCase(), StringUtils.substring(customer.getGender(),0, 1), customer.getTransaction_amount()); return row; } }