操作步骤:
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数目,称作任务并行数,任务并行数一般小于机器并行数。


相关文章:

  • 2021-09-14
  • 2021-11-18
  • 2021-12-13
  • 2021-11-14
  • 2022-12-23
  • 2022-12-23
  • 2022-12-23
猜你喜欢
  • 2022-12-23
  • 2021-12-21
  • 2021-05-15
  • 2021-06-11
  • 2022-12-23
  • 2022-01-19
  • 2022-12-23
相关资源
相似解决方案