hadoop - 如何创建协调器工作以一次(即基于日期)运行最近一个月的工作？

Question

我想创建一个协调器作业，该作业应该每月一次但每天运行一次，即它应该在月底运行，同一天它应该在一个月的所有日子运行。

例如:八月。它应在8月(2016-08-31)的月底运行，但它本身在同一天应在该月的所有天运行，即2016-08-01,2016-08-02 ... 2016-08-同一天31日，即(2016-08-31它自己拥有全部31天)。

我需要动态获取我的操作节点的日值(value)...在协调员工作的帮助下，我应该能够获得日值(value)。

请帮助我。提前致谢。

Answer 1

您可以在每月的月初运行，也可以在上个月的所有日期运行。在您的示例中，您的WF将在1/9上的2016-08-*上运行

如果要使用done-flag，则需要使用EL Function daysInMonth，因此input-events类似于:

<input-events>
        <data-in name="input" dataset="mydataset">
          <start-instance>${coord:current( -(coord:daysInMonth(0) - 1) )}</start-instance>
          <end-instance>${coord:current(0)}</end-instance>
        </data-in>
      </input-events>