纱线和集群模式下的打印火花命令

Question

我需要在火花纱线模式下打印一些命令。显然println（消息）不起作用...我想找到一种方法来收集消息。有人可以指点我目前的方法，例如使用收集？

如何使用collect？

下面的代码是否工作？

val c=message.collect() 
println (c) 

Answer 1

你可以做到这一点使用下面的命令：

message.foreach(println) 

你会发现上面的调用的输出执行日志。