Как описано в заголовке, как я могу присвоить значение переменной rdd?
Мой код выглядит так:
Var rdd1 ＝ something
For(i <- 0 to n){
rdd1＝ calculation(rdd1,other params)
rdd1.first
}
Когда я использую код выше, сЗа несколько итераций оперативная память заполнена, и некоторые диски записываются на диск, даже если я вызвал функцию unpersist.