Project

General

Profile

« Previous | Next » 

Revision 60452

Added by Claudio Atzori 11 months ago

updated hadoop aggregation workflow reporting

View differences:

modules/dnet-openaireplus-workflows/trunk/src/main/java/eu/dnetlib/msro/openaireplus/workflows/nodes/dhp/SubmitDnetHadoopJobNode.java
1 1
package eu.dnetlib.msro.openaireplus.workflows.nodes.dhp;
2 2

  
3
import eu.dnetlib.msro.rmi.MSRORuntimeException;
4 3
import org.apache.commons.logging.Log;
5 4
import org.apache.commons.logging.LogFactory;
6 5
import org.springframework.beans.factory.annotation.Autowired;
modules/dnet-openaireplus-workflows/trunk/src/main/resources/eu/dnetlib/msro/openaireplus/workflows/repo-hi/pubsRepositoryHadoop/transform.wf.st
32 32
    </ARCS>
33 33
</NODE>
34 34

  
35
<NODE name="TRANSFORM_HADOOP" type="SubmitHadoopJob">
35
<NODE name="TRANSFORM_HADOOP" type="SubmitDnetHadoopJobNode">
36 36
    <DESCRIPTION>Start the Hadoop Job</DESCRIPTION>
37 37
    <PARAMETERS>
38 38
        <PARAM managedBy="system" name="hadoopJob" required="true" type="string">executeOozieJob</PARAM>
......
52 52
                 'transformationPlugin':'XSLT_TRANSFORM'
53 53
            }
54 54
        </PARAM>
55
        <PARAM managedBy="system" name="oozieReportActionsCsv" required="true" type="string">CommitVersion</PARAM>
55 56
    </PARAMETERS>
56 57
    <ARCS>
57 58
        <ARC to="UPDATE_INFO"/>

Also available in: Unified diff