Project

General

Profile

« Previous | Next » 

Revision 60452

Added by Claudio Atzori about 3 years 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