在集群上运行代码
您在一家数据咨询公司工作,团队大量使用 R 并行代码。但最近结果不稳定,同一输入有时会得到不同输出。为进一步排查前,您决定先对每个集群做一次基础检查。
您已创建变量 test_var,并计算了其所有元素之和 test_sum。您想检查每个集群是否能准确求和该变量。已为您加载 parallel 包。
本练习是课程的一部分
R 并行编程
练习说明
- 生成一个包含 4 个核心的集群。
- 将
test_var和test_sum导出到集群。 - 若
test_var的求和等于test_sum,打印 "Accuracy OK",否则打印 "Errors"。 - 停止集群。
交互式实操练习
通过完成这段示例代码来试试这个练习。
# Make a cluster of four cores
cl <- ___
# Export test_var and test_sum to cluster
clusterExport(___, ___, envir = environment())
# Check the sum on cluster
clusterEvalQ(___, {
___
})
# Stop cluster
___