我需要定期将文件从本地文件系统加载到 hdfs 并更新配置单元表分区。更新分区的查询取决于
timestamps(select * where date = "").
可以使用 Oozie EL,但我需要今天和昨天的日期。此外,我不明白如何捕获日期并将其作为参数传递给配置单元脚本。
我该怎么做,有什么想法吗?
你可以写一个 coordinator.xml 并使用它的日期函数
${coord:dateOffset(coord:nominalTime(), -1, 'DAY')}
此处的文档:http://oozie.apache.org/docs/3.3.2/CoordinatorFunctionalSpec.html#a6.7.3._coord: nominalTime_EL_Function