从命令行或脚本中使用jags.parallel很好。我可以在上运行这个修改过的示例。
# An example model file is given in:
model.file <- system.file(package="R2jags", "model", "schools.txt")
#=================#
# initialization #
#=================#
# data
J <- 8.0
y <- c(28.4,7.9,-2.8,6.8,-0.6,0.6,
我有一个R包,它包含C-I函数,名为myFun。我想在我的并行计算中把这个叫做myFun。这个myFun本身在我的Mac上工作得很好,但是当通过并行计算函数sfClusterApplyLB调用它时,它表现出奇怪的行为:我的Mac显示加载轮,而R几乎结冰。过了一会儿,R停止冻结,sfClusterApplyLB返回并行化的结果。我真的想避免这种冻结条件,因为当R控制台结冰时,我甚至不能上下滚动!
为了说明这一点,我有一个小示例代码。
我有一个小C代码,它循环100次,同时每20秒输出迭代次数,每次迭代时睡眠1秒:
# include <R.h>
# include <Rin
我想使用IPython/Jupyter在一个计算集群上设置100个作业来执行一些计算。
在Python中,我将执行以下操作
from IPython.parallel import Client
c = Client()
c[:].apply_sync(lambda : "Hello, World")
或者,使用ipython-cluster-helper
with cluster_view(scheduler="lsf", queue="myqueue", num_jobs=100) as view:
result = view.map
用例
我正在使用Shopify的sarama libary,这是一个客户端库。更具体地说,我使用的是ClusterAdmin结构,这很好,但是我想向它添加另一个方法ListDetailedTopics,我必须调用集群管理的非公共方法。
问题
我不知道如何用我自己的方法“扩展”导出的结构。我试过这个:
func (ca *sarama.ClusterAdmin) ListDetailedtopics() {
b, err := ca.findAnyBroker() // This is a private method I need to call
}
这是因为“无效接收器类型*saram