Project

General

Profile

« Previous | Next » 

Revision 35701

Added by Mateusz Kobos about 9 years ago

Removing usage of working_dir from Java workflow node.

View differences:

PersonProducer.java
4 4 
import java.util.HashMap;
5 5 
import java.util.Map;
6 6 

  		




  
  7
  
    
import org.apache.hadoop.conf.Configuration;


  		




  7
  8
  
    
import org.apache.hadoop.fs.FileSystem;


  		




  8
  9
  
    
import org.apache.hadoop.fs.Path;


  		




  9
  10
  
    

  		




  10
  11
  
    
import eu.dnetlib.iis.core.examples.StandardDataStoreExamples;


  		




  11
  12
  
    
import eu.dnetlib.iis.core.examples.schemas.documentandauthor.Person;


  		




  12
  
  
    
import eu.dnetlib.iis.core.java.HadoopContext;


  		




  13
  13
  
    
import eu.dnetlib.iis.core.java.PortBindings;


  		




  14
  14
  
    
import eu.dnetlib.iis.core.java.Process;


  		




  15
  15
  
    
import eu.dnetlib.iis.core.java.io.DataStore;


  		




  ......




  40
  40
  
    
	}


  		




  41
  41
  
    
	


  		




  42
  42
  
    
	@Override


  		




  43
  
  
    
	public void run(PortBindings portBindings, HadoopContext context,


  		




  
  43
  
    
	public void run(PortBindings portBindings, Configuration conf,


  		




  44
  44
  
    
			Map<String, String> parameters)	throws IOException{


  		




  45
  45
  
    
		Map<String, Path> output = portBindings.getOutput();


  		




  46
  
  
    
		FileSystem fs = FileSystem.get(context.getConfiguration());


  		




  
  46
  
    
		FileSystem fs = FileSystem.get(conf);


  		




  47
  47
  
    
		


  		




  48
  48
  
    
		DataStore.create(StandardDataStoreExamples.getPerson(),


  		




  49
  49
  
    
				new FileSystemPath(fs, output.get(personPort)));


  		












Also available in:  Unified diff