转换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))