Revision 35701
Added by Mateusz Kobos about 9 years ago
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
Removing usage of working_dir from Java workflow node.