Преобразование DStream [java.util.Date] для DStream [String]

Question

Я пытаюсь объединения двух 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) 

или если вы хотите специфический формат

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