不支持 java.util.Date

Question

我想将RDD写入MYSQL，其中RDD包含java.util.Date类型。

rdd.map(f=> FeatureData(
           f.get("name").toString, 
           f.get("value").toString.toDouble, 
           f.get("time").asInstanceOf[Date],
           f.get("period").toString))
    .toDF()

在这个RDD中，time的值类型的键也是java.util.Date，它只是得到错误[查看嵌套异常:java.lang.UnsupportedOperationException:不支持 java.util.Date 类型的架构

Answer 1

首先将java.util.Date转换为java.sql.Date。然后用 java.sql.Date 的数据运行你的 sql。示例代码:

java.util.Date utilDate = new java.util.Date();
java.sql.Date sqlDate = new java.sql.Date(utilDate.getTime());

更新:AndreHolzner 建议使用 java.sql.Timestamp。我还没有尝试过，但通常 Timestamp 比 Date 好。