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:

ContextConfigurationStdoutPrinter.java
5 5
import java.util.Map;
6 6
import java.util.Map.Entry;
7 7

  
8
import eu.dnetlib.iis.core.java.HadoopContext;
8
import org.apache.hadoop.conf.Configuration;
9

  
9 10
import eu.dnetlib.iis.core.java.PortBindings;
10 11
import eu.dnetlib.iis.core.java.porttype.PortType;
11 12

  
......
32 33
	}
33 34

  
34 35
	@Override
35
	public void run(PortBindings portBindings, HadoopContext context,
36
	public void run(PortBindings portBindings, Configuration conf,
36 37
			Map<String, String> parameters) throws Exception {
37 38
		
38 39
		System.out.println("listing hadoop context configuration properties");
39
		Iterator<Entry<String,String>> ctxIt = context.getConfiguration().iterator();
40
		Iterator<Entry<String,String>> ctxIt = conf.iterator();
40 41
		while(ctxIt.hasNext()) {
41 42
			Entry<String,String> entry = ctxIt.next();
42 43
			System.out.println(entry.getKey() + "=" + entry.getValue());

Also available in: Unified diff