Apache Spark与Scala合并流文本

Question

我想合并流数据

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

这个代码工作但我需要tSender +内容格式。我试过了

println(tSender + contents) 

但它不起作用。如果有人知道某事可以帮助我吗？

Answer 1

只需提取所需的所有字段：

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