首页 ❯

不支持 java.util.Date

java apache-spark
2022-09-03 04:30:13

我想写入 ，其中包含类型。RDDMYSQLRDDjava.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()

在此，的值类型的键也是，它只是得到错误RDDtimejava.util.Date[See nested exception: java.lang.UnsupportedOperationException: Schema for type java.util.Date is not supported


答案 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());

更新：安德烈·霍尔兹纳建议使用.我还没有尝试过，但总的来说比.java.sql.TimestampTimestampDate


答案 2

推荐
更多 »
标签
更多 »
php pass-by-reference optional-parameters default-value javascript arrays dom function string object serialization tostring visibility syntax jslint use-strict operators equality equality-operator identity-operator datetime timestamp date-arithmetic redirect angularjs loops foreach iteration scope variables
推荐
更多 »