问题标签 [multidplyr]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
0 回答
22 浏览

r - 在 R 中的 multidplyr 中使用 distinct() 时出错

我在使用 R 中的 multidplyr 对少数核心进行计算时遇到问题。我有一个数据,我给它一个数字(数据将按数字分组,数字 1 的数据将被感知到集群 1 等),如下面的代码:

此外,我发送到每个将计算库、其他值和函数的集群。

数据拆分并发送到集群后,我想开始计算并收集结果:

dane %>% select() %>% distinct() %>% ...

但不幸的是我有这个错误,我不知道如何解决这个问题[而不是 distinct(),我使用唯一但其他错误显示。]

“命令'UseMethod(“distinct”)'中的错误:'distinct'的不适用方法应用于类对象“multidplyr_party_df””

0 投票
1 回答
44 浏览

r - 如何在 multidplyr 中设置超时

使用时我不一致地收到以下错误multidplyr(即,对于相同的数据,有时我会收到错误,有时不会):

rs_init 中的错误(self、private、super、options、wait、wait_timeout):无法启动 R 会话,超时

我的设置如下:

recursive_func_c调用的函数在哪里:

据我正确理解,multidplyr 集群由多个由callr. 我收到的错误消息似乎来自callr包。对于调试,我想为callrwithin设置更长的超时时间multidplyr。那可能吗?谢谢你的任何提示。

0 投票
0 回答
70 浏览

r - 当值似乎在 by="x" 参数中匹配时,为什么 left_join 创建 NA?

我正在尝试在名为 multi_scenario 和 production_targets 的两个数据帧之间执行 left_join。我正在尝试基于以下代码执行连接,使用基于匹配列 "mean_needed" 的 left_join :

这是我的两个数据框

1.multi_scenario:

  1. 生产目标:

我期待上面的代码将两个新列(rel_production 和 production_target)添加到我的新数据框comb 中,并带有关联的值。但是,由于某种原因,我的新数据框在某些区域显示 NA 而不是预期值。这似乎只发生在对 mean_needed 的某些观察中。但是,当我查看要加入的两个数据框中的 mean_needed 值时,它们看起来是相同的。没有任何额外的隐藏空格,并且两列都是数字。我包含一个打印件以显示两列中的 mean_needed 值似乎相同。我得到 NA 而不是期望值有什么原因吗?谢谢

梳数据框,显示某些平均值的 NA。加入后在其他 mean_values 处重复分配 NA

我试图通过以下方式离开的价值观:

0 投票
0 回答
80 浏览

r - 结合dtplyr和multidplyr处理大型mutate操作

我正在组合dtplyrmultidplyr库来处理在一个非常大的数据库上执行的一些基本的变异/汇总操作。final_db_partition,合并后有时是 30m 行长。

我不知道我是否做错了什么,但 R 会话被中止或我完成了我的记忆。

R 版本 4.0.5 (2021-03-31) / 平台:x86_64-apple-darwin17.0 (64-bit) / 运行于:macOS Big Sur 10.16

我应该如何解决这个问题?

0 投票
0 回答
667 浏览

r - 错误:包“Rcpp”未提供函数“Rcpp_precious_remove”

我正在尝试实现此处给出的示例:https ://cran.r-project.org/web/packages/multidplyr/vignettes/multidplyr.html

但是,当我需要使用以太方法 1 或 2 对数据进行分区时,出现以下错误。我尝试重新安装 Rcpp 包,但仍然无法正常工作。

qs::qsave (values, path, preset = "fast", check_hash = FALSE, : 函数 'Rcpp_precious_remove' 未由包 'Rcpp' 提供) 中的错误

下面是代码示例: