Apache Spark mit Scala Merge Text Streaming

Question

ich Streaming-Daten

val contents = tweets.map(status => status.getText()) 
val tSender = tweets.map(status => status.getUser().getScreenName()) 
tSender.print() 
contents.print() 

Diese Codes arbeiten zusammenführen möchten, aber ich muss tSender + Inhalt Format. Ich versuchte

println(tSender + contents) 

aber es funktioniert nicht. Wenn jemand über etw weiß, kann mir das helfen?

Answer 1

einfach extrahieren alle Felder möchten Sie zusammen:

tweets.map(status => 
    s"${ status.getUser().getScreenName()} ${status.getText()}" 
).print