Печать команды искры в режиме пряжи и кластера

Question

Мне нужно напечатать некоторые команды в режиме искровой пряжи. Очевидно, println (message) не работает ... Я хочу найти способ для сбора сообщения. Может ли кто-нибудь указать мне на текущий метод, например, используя collect?

Как использовать коллекцию?

Работает ли этот код ниже?

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

Answer 1

Вы можете достичь этого, используя следующую команду:

message.foreach(println) 

Вы найдете выход выше вызова в журналах исполнителя.