Database Reference
In-Depth Information
17 <configuration>
18 <property>
19 <name>mapred.job.queue.name</name>
20 <value>${queueName}</value>
21 </property>
22 </configuration>
23 <script>manufacturer.pig</script>
24 </pig>
25 <ok to="pig-join"/>
26 <error to="fail"/>
27 </action>
28
29 <action name="pig-model">
30 <pig>
31 <job-tracker>${jobTracker}</job-tracker>
32 <name-node>${nameNode}</name-node>
33 <prepare>
34 <delete path="${hdfsEntityData}/model"/>
35 </prepare>
36 <configuration>
37 <property>
38 <name>mapred.job.queue.name</name>
39 <value>${queueName}</value>
40 </property>
41 </configuration>
42 <script>model.pig</script>
43 </pig>
44 <ok to="pig-join"/>
45 <error to="fail"/>
46 </action>
47
48 <join name="pig-join" to="hive-fork"/>
49
50 <fork name="hive-fork">
51 <path start="hive-manufacturer"/>
52 <path start="hive-model"/>
53 </fork>
54
55 <action name="hive-manufacturer">
56 <hive xmlns="uri:Oozie workflow:hive-action:0.2">
57 <job-tracker>${jobTracker}</job-tracker>
58 <name-node>${nameNode}</name-node>
59 <configuration>
60 <property>
61 <name>mapred.job.queue.name</name>
62 <value>${queueName}</value>
63 </property>
64 </configuration>
65 <script>model.sql</script>
66 </hive>
67 <ok to="hive-join"/>
Search WWH ::




Custom Search