如何使用决策节点检查oozie工作流中的分区位置是否存在。示例:/user/cloudera/ year=2016/month=201609/day=20150912
在我的hdfs的位置,我会得到一个数据集,每天像上面。即。。。 year=2016/month=201609/day=20150912
在协调工作的帮助下,我将得到日期值
<property>
<name>today</name>
<value>${coord:formatTime(coord:dateOffset(coord:dateTzOffset(coord:nominalTime(), "America/Los_Angeles"), -1, 'DAY'), 'yyyyMMdd')}</value>
</property>
在我的工作流中,借助决策节点,如何检查 year=2016/month=201609/day=20150912
路径是否存在?
3条答案
按热度按时间s4n0splo1#
您可以使用oozie工作流el函数中的hcatalog el函数:
指定hcatalog表分区uri的格式为
例如:
jdzmm42g2#
感谢您及时回复@younghobbit和@dennis jaheruddin。
我想使用decision节点来检查路径是否存在,而不是uri。我发现coordinate job和workflow.xml帮助我实现了解决方案。
坐标\u job.xml
我的工作流.xml:
jtjikinw3#
似乎这是您要检查的位置:
当然,您可以在需要时用正确的偏移量来纠正这些问题。