微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

spark 解决 java.util.Date is not a valid external type for schema of Date

出错伪代码如下:

//出错的点在这里
import java.util.Date
...

val t_rdd = t_frame.rdd.map(row => {
      val photo_url = row.getAs[String]("photo_url")
      val longitude = row.getAs[String]("longitude")
      val latitude = row.getAs[String]("latitude")
      val imei = row.getAs[String]("imei")
      val pic_time = row.getAs[String]("pic_time")
      val date_pic_time = new Date(pic_time.toLong)

      Row(
        photo_url,
        longitude,
        latitude,
        imei,
        date_pic_time,
      )
)

val structType = StructType(
      Seq(
        StructField("photo_url", StringType, nullable = true),
        StructField("longitude", StringType, nullable = true),
        StructField("latitude", StringType, nullable = true),
        StructField("imei", StringType, nullable = true),
        StructField("pic_time", DateType),
    )
)
spark.createDataFrame(t_rdd, structType)

当时有RowstructType 来创建DataFrame时,Date的类型必须是java.sql.Date, 而如果是java.util.Date 在后续操作过程中会报 java.util.Date is not a valid external type for schema of Date

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐