轉換DSTREAM [java.util.Date]到DSTREAM [字符串]

Question

我想聯盟2個Dstreams：

val statuses = tweets.map(status => status.getText()) 
    val users = tweets.map(status => status.getUser()) 
    val Dates = tweets.map(status => status.getCreatedAt()) 
    (statuses. union(Dates)).print 

但我發現了一個錯誤，存在類型不匹配：

Found: org.apache.spark.streaming.dstream.DStream[java.util.Date] 

Required: org.apache.spark.streaming.dstream.DStream[String] 

我該如何做轉換？

Answer 1

試試這個

val Dates = tweets.map(status => status.getCreatedAt.toString) 

，或者如果你想[轉換java.util.Date爲String]特定格式

val format = new SimpleDateFormat("yyyy-MM-dd") 
val Dates = tweets.map(status => format.format(status.getCreatedAt))