Project

General

Profile

« Previous | Next » 

Revision 47494

Added by Michele Artini almost 7 years ago

View differences:

CollectJobNode.java
12 12 

  		




  13
  13
  
    
import eu.dnetlib.clients.is.InformationServiceClient;


  		




  14
  14
  
    
import eu.dnetlib.msro.annotations.ProcessNode;


  		




  15
  
  
    
import eu.dnetlib.msro.annotations.ToEnv;


  		




  16
  15
  
    
import eu.dnetlib.msro.workers.aggregation.objects.InterfaceDescriptor;


  		




  17
  16
  
    
import eu.dnetlib.msro.workflows.Arc;


  		




  18
  17
  
    
import eu.dnetlib.msro.workflows.nodes.SimpleParallelProcessNode;


  		




  ......




  30
  29
  
    

  		




  31
  30
  
    
	private String datasourceId;


  		




  32
  31
  
    
	private String datasourceInterface;


  		




  33
  
  
    

  		




  34
  
  
    
	@ToEnv


  		




  35
  32
  
    
	private Stream<String> outputStream;


  		




  36
  33
  
    

  		




  37
  34
  
    
	@Override


  		












Also available in:  Unified diff