#java #apache-spark #apache-spark-sql #apache-spark-dataset
Вопрос:
У меня есть следующее POJO:
public class Person implements Serializable { private Integer name; @SerializedName("date_of_birth") private Date dateOfBirth; }
И я хочу преобразовать фрейм данных из следующих столбцов: имя, data_of_birth в список этого POJO. Типы POJO и DF подходят друг другу. Я попробовал следующее:
Encoderlt;Persongt; personEncoder = Encoders.bean(Person.class); Datasetlt;Persongt; personDS = result.as(personEncoder); Listlt;Persongt; personList = personDS.collectAsList();
Но это не сработало из-за названий полей POJO. Я пытался аннотировать их с помощью Gson @SerializedName()
, но это тоже не сработало.