Project

General

Profile

« Previous | Next » 

Revision 46425

Added by Michele Artini about 7 years ago

async communication

View differences:

TransformJobNode.java
9 9 
import eu.dnetlib.msro.annotations.EnvParam;
10 10 
import eu.dnetlib.msro.annotations.ProcessNode;
11 11 
import eu.dnetlib.msro.workflows.Arc;
12 
import eu.dnetlib.msro.workflows.nodes.AbstractProcessNode;
12 
import eu.dnetlib.msro.workflows.nodes.AbstractParallelProcessNode;
13 13 

  		




  14
  14
  
    
@Component


  		




  15
  15
  
    
@Scope("prototype")


  		




  16
  16
  
    
@ProcessNode("Transform")


  		




  17
  
  
    
public class TransformJobNode extends AbstractProcessNode {


  		




  
  17
  
    
public class TransformJobNode extends AbstractParallelProcessNode {


  		




  18
  18
  
    

  		




  19
  19
  
    
	@EnvParam(value = "DATA_IN", direction = Direction.IN)


  		




  20
  20
  
    
	private Stream<String> in;


  		












Also available in:  Unified diff