在oozie输入路径中使用两个连续日期

qyswt5oh  于 2021-05-27  发布在  Hadoop
关注(0)|答案(0)|浏览(324)

我已将协调器配置为从输入路径开始,该路径使用前一个日期。我已经完成了 coord:current(-1) 正如这里所建议的:如何为前一天配置oozie协调器数据集,它工作正常。以下是完整代码:

<datasets>
    <dataset name="my_flag" frequency="${coord:days(1)}"
             initial-instance="2020-08-22T04:09Z" timezone="Africa/Ceuta">
      <uri-template>${nameNode}/user/user123/data/_SUCCESS_${YEAR}${MONTH}${DAY}</uri-template>
      <done-flag></done-flag>
    </dataset>
</datasets>
<input-events>
    <data-in name="my_flag" dataset="my_flag">
      <instance>${coord:current(-1)}</instance>
    </data-in>
</input-events>

但现在我需要以以下格式指定输入路径: /user/user123/data/${YEAR}${MONTH}${DAY}/_SUCCESS_${YEAR2}${MONTH2}${DAY2} ,其中${year2}${month2}${day2}是 coord:current(0) 我不知道该怎么做。
指定可以使用的参数 coord:dateOffset(coord:nominalTime(), -1, 'DAY') 对于我的问题,什么是完美的解决方案,但我无法使它在输入路径中工作。
注意:为了使代码更清晰,我简化了一点路径,第二个日期的用例是插入日期,它可以不同于数据所涉及的日期。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题