Oozie:如何定义Oozie的工作流（workflow）

工作流引擎Oozie（驭象者），用于管理Hadoop任务（支持MapReduce、Spark、Pig、Hive），把这些任务以DAG（有向无环图）方式串接起来。Oozie任务流包括：coordinator、workflow；workflow描述任务执行顺序的DAG，而coordinator则用于定时任务触发，相当于workflow的定时管理器，其触发条件包括两类：

?1. 数据文件生成

?2. 时间条件

?Oozie定义了一种基于XML的hPDL （Hadoop Process Definition Language）来描述workflow的DAG。在workflow中定义了

?1. 控制流节点（Control Flow Nodes）

?2. 动作节点（Action Nodes）

?其中，控制流节点定义了流程的开始和结束（start、end），以及控制流程的执行路径（Execution Path），如decision、fork、join等；而动作节点包括Hadoop任务、SSH、HTTP、eMail和Oozie子流程等。

step1. 修改job.properties

step2. 修改workflow.xml

step3. 将自定义的wordcount程序，打包成jar包放在lib目录下

step4. 将oozie-apps整个文件上传到hdfs文件系统上

step4. 执行Oozie job

注意事项：

在本地文件oozie 文件下，也需要有和hdfs文件系统相匹配的job.properties目录才可以。也就是说：

至此，执行一个Oozie 的mapreuce工作流的过程结束！