调度参数 | 参数取值 | 参数描述 |
实例数据时间 | ${…} 是自定义参数格式的时间参数。通过 yyyy 表示4位的年份,yy 表示2位的年份,MM 表示月,dd 表示天,HH 表示小时,mm 表示分钟,ss 表示秒。可以任意组合参数,例如${yyyyMMdd}、${yyyy-MM-dd}、${HH:mm:ss} 和${yyyyMMddHHmmss} 等 | 指任务处理业务数据的时间,精确到秒。数据时间可通过 ${yyyyMMddHHmmss} 获取。 默认T + 0方式,数据时间规则如下: 分钟任务,数据时间 = 计划调度时间 ; 小时任务,数据时间为 yyyy-MM-dd HH:00:00(yyyy-MM-dd HH 与计划调度时间一致); 天、周、年、月任务,数据时间为 yyyy-MM-dd 00:00:00(yyyy-MM-dd 与计划调度时间一致)。 对于测试运行,获取时间是提交执行时间。 常用参数: ${yyyyMMdd} ${yyyy-MM-dd} ${HH:mm:ss} ${yyyyMMddHHmmss} |
计划调度时间 | $(…) 是自定义参数格式的时间参数。 | 指实例计划调度时间,也是实例生成时间,精确到秒。计划调度时间可通过$(yyyyMMddHHmmss) 获取。 常用参数: $(yyyyMMdd) |
时间 | 时间参数格式 | 备注 |
后 N 年 | ${yyyyMMdd+Ny} | 若引用 dt=${yyyyMMdd-1M},将执行替换:dt=20210610
若引用 ,将执行替换:dt=20210709
若引用 time=${yyyyMMddHHmmss-3h},将执行替换:time=20210710050000
若引用 ti=${yyyyMMddHHmmss-25m},将执行替换:ti=20210710073500 |
前 N 年 | ${yyyyMMdd-Ny} | |
后 N 月 | ${yyyyMMdd+NM} | |
前 N 月 | ${yyyyMMdd-NM} | |
后 N 周 | ${yyyyMMdd+Nw} | |
前 N 周 | ${yyyyMMdd-Nw} | |
后 N 天 | ${yyyyMMdd+Nd} | |
前 N 天 | ${yyyyMMdd-Nd} | |
后 N 小时 | ${yyyyMMddHHmmss+NH} | |
前 N 小时 | ${yyyyMMddHHmmss-NH} | |
后 N 分钟 | ${yyyyMMddHHmmss+Nm} | |
前 N 分钟 | ${yyyyMMddHHmmss-Nm} | |
调度时间戳(10位) | ${timestamp} | ${timestamp}=1625875200
支持使用 “+”、“-” 等运算符处理。 |
调度时间戳(13位) | ${timestamp_ms} | ${timestamp_ms}=1698508800000 支持使用 “+”、“-” 等运算符处理。 |
序号 | 时间参数格式 | 说明 |
1 | ${yyyyMMdd+TE} | TENDAY END 数据日期对应旬末 |
2 | ${yyyyMMdd+ME} | MONTH END 数据日期对应月末 |
3 | ${yyyyMMdd+QE} | QUARTER END 数据日期对应季末 |
4 | ${yyyyMMdd+HYE} | HALF YEAR END 数据日期对应半年末 |
5 | ${yyyyMMdd+YE} | YEAR END 数据日期对应年末 |
6 | ${yyyyMMdd+TS} | TENDAY START 数据日期对应旬初 |
7 | ${yyyyMMdd+MS} | MONTH START 数据日期对应月初 |
8 | ${yyyyMMdd+HYS} | HALFYEAR START 数据日期对应半年初 |
9 | ${yyyyMMdd+YS} | YEAR START 数据日期对应年初 |
10 | ${yyyyMMdd+PME} | PRI MONTH END 数据日期对应上月月末 |
11 | ${yyyyMMdd+PYE} | PRI YEAR END 数据日期上年年末 |
时间 | 时间参数格式 | 备注 |
调度时间 | $(yyyyMMddHHmmss) | 若引用 dt=$(yyyyMMdd-1M),将执行替换:dt=20210610 若引用 ,将执行替换:dt=20210709 若引用 time=$(yyyyMMddHHmmss-3h),将执行替换:time=20210710050000 若引用 ti=$(yyyyMMddHHmmss-25m),将执行替换:ti=20210710073500 |
后 N 年 | $(yyyyMMdd+Ny) | |
前 N 年 | $(yyyyMMdd-Ny) | |
后 N 月 | $(yyyyMMdd+NM) | |
前 N 月 | $(yyyyMMdd-NM) | |
后 N 周 | $(yyyyMMdd+Nw) | |
前 N 周 | $(yyyyMMdd-Nw) | |
后 N 天 | $(yyyyMMdd+Nd) | |
前 N 天 | $(yyyyMMdd-Nd) | |
后 N 小时 | $(yyyyMMddHHmmss+NH) | |
前 N 小时 | $(yyyyMMddHHmmss-NH) | |
后 N 分钟 | $(yyyyMMddHHmmss+Nm) | |
前 N 分钟 | $(yyyyMMddHHmmss-Nm) | |
调度时间戳 | $(timestamp) | $(timestamp)=1625875200 支持使用 “+”、“-” 等运算符处理。 |
参数 | 含义 |
${projectIdent} | 项目标识 |
${workflowName} | 工作流名称 |
${taskName} | 任务名称 |
${taskId} | 任务 ID |
${taskInCharge} | 责任人 |
${taskType} | 任务类型 |
select "${projectIdent}" as projectIdent, "${workflowName}" as workflowName, "${taskName}" as taskName, "${taskId}" as taskId, "${taskInCharge}" as taskInCharge, "${taskType}" as taskType, user_id from wedata_demo_db.user_info limit 10;
--name ${projectIdent}-${workflowName}-${taskInCharge}
spark.app.name=${projectIdent}-${workflowName}-${taskInCharge}
本页内容是否解决了您的问题?