-
Notifications
You must be signed in to change notification settings - Fork 8
(DataFlow) Instruction sets
成文 edited this page Jul 1, 2021
·
2 revisions
1 上下文控制指令
名称 | 参数说明 | 用途 | 约束 |
Track.cpuPrepare->instance | instance,实例名称 | 准备运行实例环境 | 必须与Track.cpuFree成对使用 |
Track.cpuFree | 无需参数 | 释放运行实例环境 | 必须与Track.cpuPrepare成对使用 |
注:以上为特种指令,所有其他指令运行之前都需要该指令先行,以获取运行环境才可以运行
2 定义与获取变量
名称 | 参数说明 | 用途 |
Track.store->key,val | key字符串,val为对象 | 设置临时变量值 |
Track.fetch->key | key字符串 | 获取变量值 |
3 控制指令函数
名称 | 参数说明 | 用途 | 约束 |
TaskControl.setIncrementPosition->position | position,增量扫描值 | 移动增量位置 | |
TaskControl.moveFullPosition->start,days,ride | 如果start>当前时间点(current),start+days*3600*24*ride;否则current+days*3600*24*ride | 移动全量位置 | 必须与Track.cpuPrepare成对使用 |
4 数据源指令
名称 | 参数说明 | 用途 | 约束 |
Pond.deleteByKey->storeId,keyColumn,keyVal | 当前存储标识(a/b),主键字段,主键值 | 删除单条记录 | |
Pond.optimizeInstance->mainName,storeId | mainName(实例名称且含来源库标识(如果有来源库标识),当前存储标识(a/b) | 优化数据存储 |
ElasticFlow