Nie rozumiem dlaczego nie chwyta side effect w poniższym przykładzie:
val data2: RDD[Array[Int]] = data.filter(x => !x.contains(i))
println(data2.count()) // 4343
var y = 2
data2.map(x => {
y = 3
})
println("y =" + y) // y = 2
skoro zapuszczam map
po 4343 elementach to powinien mi 4343 zmienić wartość y
na 3
(wiem, że nie ma to sensu, to tylko przykład. W rzeczywistości chcę dodawać se elementy do kolejki używając .map(x => ++= x)
)