集算器集群调用



操作步骤:
1.参与集群的每个节点均需要安装部署集算器;
2.将参与集群计算的网格文件(dfx)放到集群的每个节点机的相同目录下,以便后续并行计算callx调用
3.每个节点机上的unit.xml(文件目录:...\esProc\config文件夹下)文件中配置所有参与并行计算的机器ip和端口号,如下图:

 
4.主机上运行datastore.exe(文件目录:...\esProc\bin文件夹下),如下图:

 

   然后选中需要启动的节点  右键  启动  启动后如下图:

5.主机上启动集算器esproc.exe   然后运行主脚本,主脚本中会将各个分机的执行结果进行汇总最终返回,如下图:

实例:
启动3个集群服务器,在集群中,分20个部分分块读取数据,统计大数据文件Emp1M.txt中,指定州(如Texas)的员工总数
对应网格文件及Emp1M.txt:
链接:https://pan.baidu.com/s/1kWpyyZt 密码:9th5

unit.xml相关节点说明:
ip是服务器的ip地址,port是指定的端口号,nodeTask是该服务器允许执行的机器并行数,
callxTask是每个callx能在该分机并行的最大任务数,通常应该不超过物理机器的cpu数目,称作任务并行数,任务并行数一般小于机器并行数。


猜你喜欢

转载自blog.csdn.net/RQlyc/article/details/79169351