我使用的是Spark2.1,我想编写一个Person列表,因为dataframe.Person类有一个嵌套的javabean类Address 人员: public class Person {ListPerson的数据帧 import org.apache.spark.sql.Dataset;import org
()....load().as(Encoders.bean(Foo.class));Caused by: java.lang.ClassCastException: test.Bar cannot be cast to test.Foo
at org.apache.spark.sql.catalyst.optimizer.CombineTypedFilte
Scala问题: JSON数据被提取并存储到case类中,需要将时间字符串数据转换为用于Spark dataframe的sql时间戳和用于Salat DAO/Mongo存储的Java/Joda日期。而且两者都不支持对方的格式。目前,我们使用两个case类进行相同的操作:
case class A(a:int, b:string, time:java.sql.timestamp)