Revision 40561
Added by Eri Katsari over 8 years ago
| modules/dnet-openaire-stats-workflow/trunk/src/main/resources/eu/dnetlib/iis/core/javamapreduce/stats/oozie_app/workflow.xml | ||
|---|---|---|
| 17 | 17 |
</property> |
| 18 | 18 |
</configuration> |
| 19 | 19 |
</global> |
| 20 |
<start to='get-scanner'/>
|
|
| 21 |
|
|
| 20 |
<start to='mr_export'/>
|
|
| 21 |
<!-- |
|
| 22 | 22 |
<action name='get-scanner'> |
| 23 | 23 |
<java> |
| 24 | 24 |
<main-class>eu.dnetlib.iis.core.workflows.stats.HbaseScannerGenerator</main-class> |
| 25 |
<!-- column families: --> |
|
| 26 | 25 |
<arg> |
| 27 | 26 |
-f person datasource , datasourceOrganization_provision_provides, |
| 28 | 27 |
organization, project, projectOrganization_participation_hasParticipant, |
| ... | ... | |
| 34 | 33 |
<ok to="mr_export" /> |
| 35 | 34 |
<error to="fail" /> |
| 36 | 35 |
</action> |
| 36 |
--> |
|
| 37 | 37 |
<action name="mr_export"> |
| 38 | 38 |
<map-reduce> |
| 39 | 39 |
|
| ... | ... | |
| 151 | 151 |
<name>mapreduce.multipleoutputs</name> |
| 152 | 152 |
|
| 153 | 153 |
<value> |
| 154 |
${out1} ${out2} ${out3} ${out4} ${out5} ${out6} ${out7} ${out8} ${out9} ${out10} ${out11} ${out12} ${out13} ${out14} ${out15} ${out16} ${out17} ${out18} ${out19} ${out20} ${out21} ${out22}
|
|
| 154 |
${out1} ${out2} ${out3} ${out4} ${out5} ${out6} ${out7} ${out8} ${out9} ${out10} ${out11} ${out12} ${out13} ${out14} ${out15} ${out16} ${out17} ${out18} ${out19} ${out20}
|
|
| 155 | 155 |
</value> |
| 156 | 156 |
|
| 157 | 157 |
</property> |
| ... | ... | |
| 433 | 433 |
<value>org.apache.hadoop.mapreduce.lib.output.TextOutputFormat</value> |
| 434 | 434 |
</property> |
| 435 | 435 |
|
| 436 |
|
|
| 436 | 437 |
<!-- persons --> |
| 437 |
<property> |
|
| 438 |
|
|
| 439 |
<!-- <property> |
|
| 438 | 440 |
<name>mapreduce.multipleoutputs.namedOutput.${out21}.key</name>
|
| 439 | 441 |
<value>org.apache.hadoop.io.Text</value> |
| 440 | 442 |
</property> |
| ... | ... | |
| 446 | 448 |
<name>mapreduce.multipleoutputs.namedOutput.${out21}.format</name>
|
| 447 | 449 |
<value>org.apache.hadoop.mapreduce.lib.output.TextOutputFormat</value> |
| 448 | 450 |
</property> |
| 451 |
--> |
|
| 449 | 452 |
|
| 450 |
|
|
| 451 | 453 |
<!-- person results--> |
| 452 |
<property> |
|
| 454 |
<!-- <property>
|
|
| 453 | 455 |
<name>mapreduce.multipleoutputs.namedOutput.${out22}.key</name>
|
| 454 | 456 |
<value>org.apache.hadoop.io.Text</value> |
| 455 | 457 |
</property> |
| ... | ... | |
| 461 | 463 |
<name>mapreduce.multipleoutputs.namedOutput.${out22}.format</name>
|
| 462 | 464 |
<value>org.apache.hadoop.mapreduce.lib.output.TextOutputFormat</value> |
| 463 | 465 |
</property> |
| 466 |
--> |
|
| 464 | 467 |
|
| 465 |
|
|
| 466 | 468 |
<!-- ## Classes of mapper and reducer --> |
| 467 | 469 |
|
| 468 | 470 |
<property> |
Also available in: Unified diff
fixes for trunk