2

场景: 输入文件:file1.log、file2.log

我只想在存在上述 2 个输入文件时触发协调器。是否可以作为文件观察者?

提前致谢。

4

1 回答 1

3

是的。你绝对可以做到这一点。协调器应用程序的输入事件指定执行协调器操作所需的输入条件。这是来自 GITHUB https://github.com/yahoo/oozie/wiki/Oozie-Coord-Use-Cases的示例

$ cat coordinator.xml
<coordinator-app name="MY_APP" frequency="1440" start="2009-02-01T00:00Z" end="2009-02-07T00:00Z" timezone="UTC" xmlns="uri:oozie:coordinator:0.1">
   <datasets>
      <dataset name="input1" frequency="60" initial-instance="2009-01-01T00:00Z" timezone="UTC">
         <uri-template>hdfs://localhost:9000/tmp/revenue_feed/${YEAR}/${MONTH}/${DAY}/${HOUR}</uri-template>
         <done-flag>trigger.dat</done-flag>
      </dataset>
   </datasets>
   <input-events>
      <data-in name="coordInput1" dataset="input1">
          <start-instance>${coord:current(-23)}</start-instance>
          <end-instance>${coord:current(0)}</end-instance>
      </data-in>
   </input-events>
   <action>
      <workflow>
         <app-path>hdfs://localhost:9000/tmp/workflows</app-path>
      </workflow>
   </action>     
</coordinator-app> 
于 2014-11-04T09:37:35.490 回答