E 使用说明 运行 状态 存储 读取
*存储运行状态abc到第一个参数(共3个,1,2,3)
**只要日志里是FS.Run.Save.Param:开头的,就会自动存储到运行状态表里。 **echo "FS.Run.Save.Param:1:abc"
*状态的读取 **fs.run.get.param(ID,index) ***ID就是节点ID,index是第几个参数,默认=1(或2,或3)
**只要日志里是FS.Run.Save.Param:开头的,就会自动存储到运行状态表里。 **echo "FS.Run.Save.Param:1:abc"
*状态的读取 **fs.run.get.param(ID,index) ***ID就是节点ID,index是第几个参数,默认=1(或2,或3)
E 使用说明 函数 类型
type=function
*input 代表子函数要激活的节点 *output 中的节点激活后代表这个子函数运行完毕。
program= { "input":"1,2", "output":"3,4", "var1":"函数.变量1", "var2":"函数.变量2", "var3":"函数.变量3" }
*input 代表子函数要激活的节点 *output 中的节点激活后代表这个子函数运行完毕。
E 使用说明
程序开头写上"#Clear_Jobs_Tables();"
就会自动清空所有当前维度(D4相同)的表和任务的激活状态
比如要多次调用
比如要多次调用
E 映射表 FS
增加映射表(node.table.clone),
这样,有的表就不需要画很长的线了
这样,有的表就不需要画很长的线了
E 注意事项
快要淘汰的节点,输入zzz
E 使用说明
*调度系统上面的节点怎么删掉呢?
**不用删除,设置D4=4或者覆盖掉即可
E 注意事项
hive模板最后一个命令必须是hive命令
后面不要跟随其他命令,否则有错误,调度系统也无法知道
E 注意事项
代码可以用
*{输入1} {输入2} *{输出1} {输出2}
简化输入表和输出表的输入
*{输入1} {输入2} *{输出1} {输出2}
简化输入表和输出表的输入
E 其他
引用程序
*{cite:xxx}
比如,引用123这个节点的程序。可以这样输入: *{cite:123}
引用程序可以循环嵌套,最多9次
比如,引用123这个节点的程序。可以这样输入: *{cite:123}
引用程序可以循环嵌套,最多9次
E 其他 网址
如果要引用某个表中的程序,可以这样
{输入1.Program}
{输入1.Program}
E 其他 批量 执行 脚本
#!/bin/bash clear index=$2 index2=$3 for i in $(seq $index $index2); do j=`expr $4 - $i` echo $j /home/dm/happyli/node_$1.sh $j done;
*使用方法 **./bat.sh 657 1 130 131
E 简化 语法 删除表
简化语法
*{删除表} xxx; **Drop Table if exists xxx
*{创建表} xxx **Create Table if not exists xxx
*{删除表} xxx; **Drop Table if exists xxx
*{创建表} xxx **Create Table if not exists xxx