我正在尝试对我的数据集进行分区,以便将组的所有成员发送到同一个核心,我正在逐字关注在线教程,但似乎存在问题。错误是:分区错误(。,组,集群=集群):未使用的参数(组)
data<-sqlQuery(conn,Query) ##import data according to query
cl<-as.numeric(detectCores())##find the number of cores
clust<-new_cluster(detectCores())
clust<-default_cluster()
data <- data %>% group_by(rowno_dmddmhi_dmd) %>% mutate(group = sample(1:cl,1))
####clustering
by_group<-data%>%partition(group, cluster = clust)
因为我有 16 个核心,每个组都分配了一个 1:16 的数字,这个数字保存在组列中