Project

General

Profile

« Previous | Next » 

Revision 60384

Added by Claudio Atzori about 3 years ago

updated hadoop-specific aggregation workflows

View differences:

modules/dnet-openaireplus-workflows/trunk/src/main/resources/eu/dnetlib/msro/openaireplus/workflows/repo-hi/pubsRepositoryHadoop/collection.wf.st
38 38 
    </ARCS>
39 39 
</NODE>
40 40 

  		




  41
  
  
    
<NODE name="COLLECT_HADOOP" type="SubmitHadoopJob">


  		




  
  41
  
    
<NODE name="COLLECT_HADOOP" type="SubmitDnetHadoopJobNode">


  		




  42
  42
  
    
    <DESCRIPTION>Start the Hadoop Job</DESCRIPTION>


  		




  43
  43
  
    
    <PARAMETERS>


  		




  44
  44
  
    
        <PARAM managedBy="system" name="hadoopJob" required="true" type="string">executeOozieJob</PARAM>


  		




  ......




  62
  62
  
    
                "oozie.wf.application.path":"oozieWfPath"


  		




  63
  63
  
    
            }


  		




  64
  64
  
    
        </PARAM>


  		




  
  65
  
    
        <PARAM managedBy="system" name="params" required="true" type="string">


  		




  
  66
  
    
            {


  		




  
  67
  
    
                "collection_java_xmx" : "-Xmx300m"


  		




  
  68
  
    
            }


  		




  
  69
  
    
        </PARAM


  		




  65
  70
  
    
        <PARAM managedBy="system" name="oozieReportActionsCsv" required="true" type="string">BeginRead,StartTransaction,CollectionWorker</PARAM>


  		




  66
  71
  
    
    </PARAMETERS>


  		




  67
  72
  
    
    <ARCS>


  		












Also available in:  Unified diff