紗線和集羣模式下的打印火花命令

Question

我需要在火花紗線模式下打印一些命令。顯然println（消息）不起作用...我想找到一種方法來收集消息。有人可以指點我目前的方法，例如使用收集？

如何使用collect？

下面的代碼是否工作？

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

Answer 1

你可以做到這一點使用下面的命令：

message.foreach(println) 

你會發現上面的調用的輸出執行日誌。