Как отфильтровать спарклир внутри фрейма для l oop? - PullRequest
0 голосов
/ 04 мая 2020

Я хочу отфильтровать внутри для l oop как

sc <- spark_connect(master = "local")
data <- spark_read_csv(sc, name = "trans_data", path = fname1, header = TRUE, delimiter = ",")
for (alternative in 1:6){
 new_data<- data %>% filter(y == alternative)
}

, но я получаю следующую ошибку

Error in UseMethod("escape") : 
  no applicable method for 'escape' applied to an object of class "c('tbl_spark', 'tbl_sql', 'tbl)"
...