Как экспортировать пользовательские функции в кластеры в multidplyr? - PullRequest
Новая
       38

Как экспортировать пользовательские функции в кластеры в multidplyr?

1 голос
/ 01 февраля 2020

Исходя из вопросов здесь и здесь , я пытаюсь заставить последнюю версию multidplyr работать с пользовательской функцией.

By способ воспроизводимого примера, я попробовал: 

library(multidplyr)
library(dplyr)
cl <- new_cluster(3)
df <- data.frame(Grp = rep(LETTERS[1:3], each = 4), Val = rep(3:1, 4))

cust_func <- function (x) {
  x + 1
}

cluster_copy(cl, "cust_func")

df_clust <- df %>%
  group_by(Grp) %>%
  partition(cl) 

df_clust %>%
  mutate(Add1 = cust_func(Val)) %>%
  collect()

Но я получаю ошибку Computation failed. Я пробовал другой порядок и несколько других мелких изменений, но не повезло.

Возможно ли экспортировать пользовательские функции в кластеры в последней версии multidplyr? Если так, то как?

...