INFO-Azkaban时间参数使用说明

适用模块

离线开发
数据传输

具体说明

1、离线开发节点参数
2、数据传输参数
3、调度参数
4、参数组参数

使用示例

1、内置时间参数:
Key name Examples Meaning
azkaban.flow.start.timestamp 2018-08-21T15:23:15.075+08:00 计划执行时间的具体时间
azkaban.flow.start.year 2018 计划执行时间的年
azkaban.flow.start.month 08 计划执行时间的月
azkaban.flow.start.day 21 计划执行时间的日
azkaban.flow.start.hour 15 计划执行时间的小时
azkaban.flow.start.minute 23 计划执行时间的分钟
azkaban.flow.start.second 15 计划执行时间的秒
azkaban.flow.start.milliseconds 075 计划执行时间的毫秒
azkaban.flow.start.timezone Asia/Shanghai 计划执行时间的时区
azkaban.flow.current.date 2018-08-21 计划执行时间日期
azkaban.flow.current.month 2019-08-01 计划执行时间所在月开始1号
azkaban.flow.current.hour 2018-08-21 15:00:00 计划执行时间所在小时的0分0秒
azkaban.flow.1.days.ago 2018-08-20 计划执行时间一天前日期
azkaban.flow.2.days.ago 2018-08-19 计划执行时间两天前日期
azkaban.flow.3.days.ago 2018-08-18 计划执行时间三天前日期
azkaban.flow.7.days.ago 2018-08-14 计划执行时间的七天前日期
azkaban.flow.30.days.ago 2018-07-22 计划执行时间的三十天前日期
schedule.exec.time 1534839814392 计划执行时间的unix时间戳
azkaban.flow.current.date.simple 20230328 计划执行时间当前时间
2Azkaban 自定义时间参数:
Azkaban推荐使用Joda Time来自定义时间以及日期的格式。更多自定义参数请用户自行参照https://www.joda.org/joda-time/
获取计划执行时间,格式为:年 -  -     :  :   
$(new("org.joda.time.DateTime", ${schedule.exec.time}).toString('YYYY-MM-dd HH:mm:ss'))
在此基础上,可使用以下方法来获取自定义时间
获取计划执行时间的前一天的零点:格式为:年 -  -    00:00:00  
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).toString('YYYY-MM-dd 00:00:00'))
注(表达式中引号需使用英文状态引号,请勿直接复制粘贴)
向前 向后
minusSeconds(n) 前 n 秒 plusSeconds(n) 后 n 秒
minusMinutes(n) 前 n 分 plusMinutes(n) 后 n 分
minusHours(n) 前 n 时 plusHours(n) 后 n 时
minusDays(n) 前 n 日 plusDays(n) 后 n 日
minusWeeks(n) 前 n 周 plusWeeks(n) 后 n 周
minusMonths(n) 前 n 月 plusMonths(n) 后 n 月
minusYears(n) 前 n 年 plusYears(n) 后 n 年
获取指定时间的时间戳   
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).toString('yyyyMMdd'))
调度执行周期前一天,格式:20211207
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).toString('yyyy-MM-dd'))
调度执行周期前一天,格式:2021-12-07
$(new("org.joda.time.DateTime", ${schedule.exec.time}).toString('yyyyMMdd'))
调度执行周期,格式:20211208
$(new("org.joda.time.DateTime", ${schedule.exec.time}).toString('yyyy-MM-dd'))
调度执行周期,格式:2021-12-08
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(2).toString('yyyyMMdd'))
调度执行周期前两天,格式:20211206
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(3).toString('yyyyMMdd'))
调度执行周期前三天,格式:20211205
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(4).toString('yyyyMMdd'))
调度执行周期前四天,格式:20211204
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(5).toString('yyyyMMdd'))
调度执行周期前五天,格式:20211203
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(6).toString('yyyyMMdd'))
调度执行周期前六天,格式:20211202
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(7).toString('yyyyMMdd'))
调度执行周期前七天,格式:20211201
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(8).toString('yyyyMMdd'))
调度执行周期前八天,格式:20211130
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(31).toString('yyyyMMdd'))
调度执行周期前31天,格式:20211107
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).toString('yyyyMM'))
调度执行周期前一天所在月,格式:202112
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).toString('yyyy-MM'))
调度执行周期前一天所在月,格式:2021-12
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).minusMonths(1).toString('yyyyMM'))
调度执行周期前一天的上个月,格式:202111
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).minusMonths(1).toString('yyyy-MM'))
调度执行周期前一天的上个月,格式:2021-11
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(0).minusMonths(1).toString('yyyyMM'))
调度执行周期当天的上个月,格式:202111
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(0).minusMonths(1).toString('yyyy-MM'))
调度执行周期当天的上个月,格式:2021-11
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).toString('yyyyMMdd'))
调度执行周期前一天,格式:20211207,主要用于调度初始化
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).toString('yyyy-MM-dd'))
调度执行周期前一天,格式:2021-12-07,主要用于调度初始化
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(15).toString('yyyyMMdd'))
调度执行周期前十五天,格式:20211123
$(new("org.joda.time.DateTime", ${schedule.exec.time}).plusDays(1).toString('yyyyMMdd'))
调度执行周期后一天,格式:20211209
$(new("org.joda.time.DateTime", ${schedule.exec.time}).plusDays(1).toString('yyyy-MM-dd'))
调度执行周期后一天,格式:2021-12-09
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).dayOfWeek().withMinimumValue().toString('yyyyMMdd'))
调度执行周期前一天所在周周一,格式20211206
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).dayOfWeek().withMinimumValue().toString('yyyy-MM-dd'))
调度执行周期前一天所在周周一,格式2021-12-06
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).dayOfWeek().withMinimumValue().minusWeeks(1).toString('yyyyMMdd'))
调度执行周期前一天的上周周一,格式20211129
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).dayOfWeek().withMinimumValue().minusWeeks(1).toString('yyyy-MM-dd'))
调度执行周期前一天的上周周一,格式2021-11-29
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).dayOfMonth().withMinimumValue().toString('yyyyMMdd'))
调度执行周期前一天的所在月第一天,格式20211201
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).dayOfMonth().withMinimumValue().toString('yyyy-MM-dd'))
调度执行周期前一天的所在月第一天,格式2021-12-01
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).dayOfMonth().withMinimumValue().minusMonths(1).toString('yyyyMMdd'))
调度执行周期前一天的所在月的上个月第一天,格式20211101
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).dayOfMonth().withMinimumValue().minusMonths(1).toString('yyyy-MM-dd'))
调度执行周期前一天的所在月的上个月第一天,格式2021-11-01
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).minusMonths(1).toString('yyyyMMdd'))
调度执行周期前一天的上月当天,格式20211107
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).minusMonths(1).toString('yyyy-MM-dd'))
调度执行周期前一天的上月当天,格式2021-11-07
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).dayOfMonth().withMinimumValue().minusYears(1).toString('yyyyMMdd'))
调度执行周期前一天所在月的去年当月第一天,格式20201201
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).dayOfMonth().withMinimumValue().minusYears(1).toString('yyyy-MM-dd'))
调度执行周期前一天所在月的去年当月第一天,格式2020-12-01
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).dayOfYear().withMinimumValue().toString('yyyyMMdd'))
调度执行周期前一天所在年第一天,格式20210101
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).dayOfYear().withMinimumValue().toString('yyyy-MM-dd'))
调度执行周期前一天所在年第一天,格式2021-01-01
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).minusYears(1).dayOfYear().withMinimumValue().toString('yyyyMMdd'))
调度执行周期前一天去年第一天,格式20200101
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).minusYears(1).dayOfYear().withMinimumValue().toString('yyyy-MM-dd'))
调度执行周期前一天去年第一天,格式2020-01-01
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).minusYears(1).toString('yyyyMMdd'))
调度执行周期前一天去年当天,格式20201207
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).minusYears(1).toString('yyyy-MM-dd'))
调度执行周期前一天去年当天,格式2020-12-07
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).toString('yyyy'))
调度执行周期前一天所在年份,格式2021
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).minusMonths(1).dayOfMonth().withMaximumValue().toString('yyyyMMdd'))
调度执行周期前一天的上个月月末,格式20211130
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).minusMonths(1).dayOfMonth().withMaximumValue().toString('yyyy-MM-dd'))
调度执行周期前一天的上个月月末,格式2021-11-30
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).minusYears(1).toString('yyyyMM'))
调度执行周期前一天去年当月,格式202012
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).minusYears(1).toString('yyyy-MM'))
调度执行周期前一天去年当月,格式2020-12
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(2).toString('yyyy-MM-dd'))
调度执行周期前两天,格式:2021-12-06
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(3).toString('yyyy-MM-dd'))
调度执行周期前三天,格式:2021-12-05
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(4).toString('yyyy-MM-dd'))
调度执行周期前四天,格式:2021-12-04
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusHours(1).toString('HH'))
调度执行周期时间前一小时,格式:01
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusHours(1).toString('yyyyMMddHH'))
调度执行周期时间前一小时,格式2022120801
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(8).toString('yyyy-MM-dd'))
调度执行周期时间前1天,格式2022-12-08
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).toString('yyyyMMdd'))
调度执行周期时间前1天,格式20221208
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusHours(1).minusMonths(1).toString('yyyyMM'))
执行周期时间前一小时的上个月月份,格式202111
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusHours(1).minusMonths(1).toString('yyyy-MM'))
执行周期时间前一小时的上个月月份,格式2021-11
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusHours(1).toString('yyyyMMdd'))
调度执行周期时间前一小时所属日期,格式yyyyMMdd
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).minusMonths(2).toString('yyyyMM'))
调度执行周期前一天的上上个月,格式:202110
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).minusMonths(2).toString('yyyy-MM'))
调度执行周期前一天的上上个月,格式:2021-10
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).toString("w"))
调度执行周期前一天为当年第几周
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).dayOfYear().withMaximumValue().toString('yyyyMMdd'))
调度执行周期前一天的所在年的最后一天,格式20211231
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).dayOfYear().withMaximumValue().toString('yyyy-MM-dd'))
调度执行周期前一天的所在年的最后一天,格式2021-12-31
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).dayOfMonth().withMaximumValue().toString('yyyyMMdd'))
调度执行周期前一天所在月最后一天,格式20211231
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).dayOfMonth().withMaximumValue().toString('yyyy-MM-dd'))
调度执行周期前一天所在月最后一天,格式2021-12-31
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).dayOfWeek().withMinimumValue().plusDays(3).toString('yyyyMM'))
计划月_日期所在周的周四所在月份
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).toString("xxxxww"))
当年第几周(202201——>202252
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).plusWeeks(1).toString("xxxxww"))
当年第几周的下一周(202201——>202252
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).plusMonths(1).toString('yyyyMM'))
昨天所在月份的下一个月(202201
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).toString('yyyyMMdd000000'))
调度执行周期前一天开始,带时分秒,格式:20211207000000
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).toString('yyyyMMdd235959'))
调度执行周期前一天结束,带时分秒,格式:20211207235959
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).plusYears(1).toString('yyyy'))
下一年,如2023
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).minusMonths(2).toString('yyyyMMdd'))
调度执行周期前一天的上上个月当天,格式20211007
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).minusMonths(2).toString('yyyy-MM-dd'))
调度执行周期前一天的上上个月当天,格式2021-10-07
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).plusWeeks(2).toString("xxxxww"))
当年第几周的下2周(202201——>202252
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).dayOfWeek().withMinimumValue().plusDays(3).plusMonths(1).toString('yyyyMM'))
计划月_日期所在周的周四所在月份_下个月
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(11).toString('yyyyMMdd'))
调度执行周期前八天,格式:20211127
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).plusMonths(1).toString('yyyy-MM'))
昨天所在的月的下一个月,格式: 2022-11
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).dayOfMonth().withMinimumValue().plusMonths(1).toString('yyyy-MM-dd'))
调度执行周期前一天所在月份的下一个月第一天(2022-01-01
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(91).toString('yyyyMMdd'))
调度执行周期时间前90天,格式20221208
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(181).toString('yyyyMMdd'))
调度执行周期时间前180天,格式20221208
$(new("org.joda.time.DateTime", ${schedule.exec.time}).dayOfWeek().withMinimumValue().toString('yyyyMMdd'))
调度执行周期所在周周一
$(new("org.joda.time.DateTime", ${schedule.exec.time}).dayOfMonth().withMinimumValue().toString('yyyyMMdd'))
调度执行周期所在月第一天
$(new("org.joda.time.DateTime", ${schedule.exec.time}).dayOfWeek().withMinimumValue().minusWeeks(1).toString('yyyyMMdd'))
调度执行周期的上周周一
$(new("org.joda.time.DateTime", ${schedule.exec.time}).dayOfMonth().withMinimumValue().minusMonths(1).toString('yyyyMMdd'))
调度执行周期的所在月的上个月第一天
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).toString('MM'))
调度执行周期前一天所在月,只有月份,格式:12
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusHours(25).toString('yyyyMMdd'))
调度执行周期时间前25小时所属日期,格式yyyyMMdd,对应南天门小时任务中v_last_day
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).minusMonths(2).toString('yyyy-MM'))
调度执行周期前二个月,以2023-02-07为例,格式:2022-12
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).minusMonths(5).toString('yyyy-MM'))
调度执行周期前五个月,以2023-02-07为例,格式:2022-09
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(91).toString('yyyy-MM-dd'))
调度执行周期前91天,格式:2021-09-08
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(9).toString('yyyyMMdd'))
调度执行周期前九天,格式:20211129
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(30).toString('yyyyMMdd'))
调度执行周期前30天,格式:20211108
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(30).toString('yyyy-MM-dd'))
调度执行周期前30天,格式:2021-11-08
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).dayOfMonth().withMinimumValue().minusMonths(4).toString('yyyy-MM-dd'))
调度执行周期前一天的所在月的上4个月第一天,格式:2022-08-01
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).dayOfMonth().withMinimumValue().minusMonths(4).toString('yyyyMMdd'))
调度执行周期前一天的所在月的上4个月第一天,格式:20220801
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).minusMonths(4).toString('yyyyMM'))
调度执行周期前一天的上4个月,格式:202111
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).minusMonths(4).toString('yyyy-MM'))
调度执行周期前一天的上4个月,格式:2021-11
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).minusMonths(2).dayOfMonth().withMaximumValue().toString('yyyyMMdd'))
调度执行周期前一天的上2个月的月底最后一天
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).minusMonths(3).dayOfMonth().withMaximumValue().toString('yyyyMMdd'))
调度执行周期前一天的上3个月的月底最后一天
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).minusMonths(4).dayOfMonth().withMaximumValue().toString('yyyyMMdd'))
调度执行周期前一天的上4个月的月底最后一天
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(7).toString('yyyy-MM-dd'))
调度执行周期前七天,格式:2021-12-01
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(92).toString('yyyyMMdd'))
调度执行周期时间前91天,格式20221208
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(31).toString('yyyy-MM-dd'))
调度执行周期前31天,格式:2021-11-07
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(16).toString('yyyy-MM-dd'))
调度执行周期前16天,格式:2021-11-23
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(39).toString('yyyy-MM-dd'))
调度执行周期前39天,格式:2021-10-30
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(9).toString('yyyy-MM-dd'))
调度执行周期前九天,格式:2021-11-29
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(16).toString('yyyyMMdd'))
调度执行周期前16天,格式:20211123
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(39).toString('yyyyMMdd'))
调度执行周期前39天,格式:20211030
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(33).toString('yyyy-MM-dd'))
调度执行周期前33天,格式:2021-11-05
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(33).toString('yyyyMMdd'))
调度执行周期前33天,格式:20211105
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(181).toString('yyyy-MM-dd'))
调度执行周期前181天,格式:2021-06-10
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(11).toString('yyyy-MM-dd'))
调度执行周期前11天,格式:2021-11-27
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(61).toString('yyyy-MM-dd'))
调度执行周期前61天,格式:2021-10-08
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(12).toString('yyyyMMdd'))
调度执行周期前12天,格式:20211126
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(12).toString('yyyy-MM-dd'))
调度执行周期前12天,格式:2021-11-26
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).minusMonths(2).toString('yyyyMM'))
执行日期前一天往前推2个月 如:202301
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(24).toString('yyyy-MM-dd'))
调度执行周期前24天,格式:2021-11-14
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(24).toString('yyyyMMdd'))
调度执行周期前24天,格式:20211114
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).toString('MM'))
执行日期前一天的月份 如:06
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusHours(1).toString('yyyyMMdd'))
执行时间1小时前的天,用于1小时调度跨天时写入分区,格式yyyymmdd
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusHours(2).toString('yyyyMMdd'))
执行时间2小时前的天,用于2小时调度跨天时写入分区,格式yyyymmdd
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusHours(6).toString('yyyyMMdd'))
执行时间6小时前的天,用于6小时调度跨天时写入分区,格式yyyymmdd
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusHours(1).toString('yyyy-MM-dd'))
执行时间1小时前的天,用于1小时调度跨天时写入分区,格式yyyy-mm-dd
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusHours(2).toString('yyyy-MM-dd'))
执行时间2小时前的天,用于2小时调度跨天时写入分区,格式yyyy-mm-dd
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusHours(6).toString('yyyy-MM-dd'))
执行时间6小时前的天,用于6小时调度跨天时写入分区,格式yyyy-mm-dd
$(new("org.joda.time.DateTime", ${schedule.exec.time}).getMillis())
当前时间的时间戳
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(1).getMillis())
当前时间前1天的时间戳
$(new("org.joda.time.DateTime", ${schedule.exec.time}).minusDays(2).getMillis())
当前时间前2天的时间戳
3、平台使用示例
3.1、离线开发节点参数

INFO-Azkaban时间参数使用说明 - 图1
INFO-Azkaban时间参数使用说明 - 图2
INFO-Azkaban时间参数使用说明 - 图3
INFO-Azkaban时间参数使用说明 - 图4
INFO-Azkaban时间参数使用说明 - 图5
INFO-Azkaban时间参数使用说明 - 图6

3.2、调度参数/运行参数

INFO-Azkaban时间参数使用说明 - 图7
INFO-Azkaban时间参数使用说明 - 图8
INFO-Azkaban时间参数使用说明 - 图9
INFO-Azkaban时间参数使用说明 - 图10
INFO-Azkaban时间参数使用说明 - 图11
INFO-Azkaban时间参数使用说明 - 图12

3.3、参数组参数

INFO-Azkaban时间参数使用说明 - 图13
INFO-Azkaban时间参数使用说明 - 图14
INFO-Azkaban时间参数使用说明 - 图15
INFO-Azkaban时间参数使用说明 - 图16
INFO-Azkaban时间参数使用说明 - 图17

3.4、数据同步

数据来源中可以作为数据过滤的筛选条件进行使用。
INFO-Azkaban时间参数使用说明 - 图18
INFO-Azkaban时间参数使用说明 - 图19

数据去向可以在分区字段中使用静态分区。
INFO-Azkaban时间参数使用说明 - 图20

作者:林帅