将 DStream[java.util.Date] 转换为 DStream[String]答案

【问题标题】：Convert DStream[java.util.Date] to DStream[String]将 DStream[java.util.Date] 转换为 DStream[String]
【发布时间】：2015-06-08 03:52:39
【问题描述】：

我正在尝试合并两个 Dstream：

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]

如何进行转换？

【问题讨论】：

Convert java.util.Date to String 的可能重复项

标签： scala apache-spark twitter4j spark-streaming

【解决方案1】：

试试这个

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

或者如果你想要特定的格式

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

【讨论】：