java.util.Date không được hỗ trợ

Question

Tôi muốn viết RDD đến MYSQL, trong đó RDD chứa java.util.Date loại.

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

Trong RDD này là chìa khóa của kiểu giá trị time 's cũng là java.util.Date và nó chỉ nhận được lỗi của [See nested exception: java.lang.UnsupportedOperationException: Schema for type java.util.Date is not supported

Answer 1

Lúc đầu chuyển đổi java.util.Date để java.sql. Ngày. Sau đó chạy sql của bạn với dữ liệu của java.sql.Date. Mẫu mã:

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