Вы можете использовать параллельные коллекции scala для достижения параллелизма foreach
со стороны водителя.
val l = List(34, 32, 132, 352).par
l.foreach{i => // your code to be run in parallel for each i}
* Однако слово предостережения: это ваш кластер, способный параллельные рабочие задания? Вы можете отправить задания в свой искровой кластер параллельно, но они могут оказаться в очереди в кластере и выполняться последовательно.