Как обновить глобальный список в нескольких функциях, используя sparkr - PullRequest
Новая
       8

Как обновить глобальный список в нескольких функциях, используя sparkr

0 голосов
/ 06 января 2019

Я хочу использовать глобальный список и изменить список в функции. Используйте этот измененный список в другой функции для дальнейшей обработки. Вся обработка должна выполняться в распределенной среде, т. Е. На рабочих узлах с использованием спаркра. Я могу сделать это в R, как указано ниже. Точно так же я хочу сделать это в SparkR. 

mylist<<-list()
print(mylist)
updatelist <- function() {
  for (i in 1:10) {
    mylist<<-append(mylist,i)
    print("list element")
    print(mylist[i])
     }
}

updatelist()
for (j in 1:10) {
  print("list outside the function")
  print(mylist[j])
  }
anotherfunc<-function(){
    for (k in 1:10) {
    print("list in another function")
    print(mylist[k])
    }
  }
anotherfunc()
...