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