/
NikolayIvkin
/
tutorials1
Обзор
Документация
Войти
/
NikolayIvkin
/
tutorials1
Код
Запросы
0
Пакеты
0
Релизы
0
Аналитика
Безопасность
master
apache-spark/src/main/java/com/baeldung/dataframes/RowToCustomerMapper.java
19 строк
544 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.api.java.function.MapFunction; import org.apache.spark.sql.Row; class RowToCustomerMapper implements MapFunction<Row, Customer> { @Override public Customer call(Row row) { Customer customer = new Customer(); customer.setId(row.getAs("id")); customer.setName(row.getAs("name")); customer.setGender(row.getAs("gender")); customer.setTransaction_amount(Math.toIntExact(row.getAs("transaction_amount"))); return customer; } }