pnodeRun

pnodeRun(function, [nodes], [addNodeAlias=true])

function 调用的本地函数（不能使用引号）。它可以是一个没有定义参数的函数，或者是没有参数的封装了初始函数和参数的部分应用。它可以是内置函数或用户自定义函数。

nodes 可选参数，字符串标量或向量，表示节点的别名。

addNodeAlias 是否在结果中加入节点的别名，默认值是 true。如果返回的结果已经包含节点的别名，可设置为false。

在集群指定节点或所有数据节点/计算节点上并行调用本地函数，然后合并结果。

• 当指定 nodes 参数时，在指定的节点上调用本地函数。

• 当未指定 nodes 参数时：若在指定了计算组的计算节点上执行该函数时，仅会在同组内的所有计算节点上调用本地函数；否则，在集群中所有的数据节点、未指定计算组的计算节点上调用本地函数。

例1. 函数 getChunksMeta 不指定参数。

pnodeRun(getChunksMeta,,false);

例2. 在下例中，函数 sum 和参数1..10被封装成了部分应用 sum{1..10}。

pnodeRun(sum{1..10}, `nodeA`nodeB);

例3. pnodeRun 对于集群管理非常方便。例如，在一个集群中有4个节点："DFS_NODE1", "DFS_NODE2", "DFS_NODE3" 和 "DFS_NODE4"。在每个节点上执行以下脚本：

def jobDemo(n){
  s = 0
  for (x in 1 : n) {
      s += sum(sin rand(1.0, 100000000)-0.5)
      print("iteration " + x + " " + s)
  }
  return s
};

submitJob("jobDemo1","job demo", jobDemo, 10);
submitJob("jobDemo2","job demo", jobDemo, 10);
submitJob("jobDemo3","job demo", jobDemo, 10);

查看集群中每个节点最近完成的两个批处理作业的状态：

pnodeRun(getRecentJobs{2});

pnodeRun(getRecentJobs{2}, `DFS_NODE3`DFS_NODE4);

pnodeRun 合并多个节点的结果时遵循以下规则：

(1) 如果 function 返回一个标量：

返回一个表，它具有两列：节点别名和函数结果。

紧接上面的例子：

pnodeRun(getJobReturn{`jobDemo1});

(2) 如果 function 返回一个向量：

返回一个矩阵。矩阵中的每一列是函数在节点上返回的结果。矩阵的列标签是节点。

(3) 如果 function 返回键-值形式的字典：

返回一个表，每行代表函数在一个节点上的结果。

(4) 如果 function 返回一个表：

返回一个表，它是多个节点上的表的合并。

(5) 如果 function 是一个命令（该命令不返回任何内容）：

不返回任何内容。

(6) 对于其他情况：

返回一个字典。键是节点别名，值是函数的返回内容。