Revision 35701
Added by Mateusz Kobos about 9 years ago
| ActionSetManagementProcess.java | ||
|---|---|---|
| 6 | 6 |
|
| 7 | 7 |
import javax.xml.ws.wsaddressing.W3CEndpointReferenceBuilder; |
| 8 | 8 |
|
| 9 |
import org.apache.hadoop.conf.Configuration; |
|
| 9 | 10 |
import org.apache.log4j.Logger; |
| 10 | 11 |
|
| 11 | 12 |
import eu.dnetlib.actionmanager.rmi.ActionManagerService; |
| ... | ... | |
| 13 | 14 |
import eu.dnetlib.actionmanager.set.ActionManagerSet.ImpactTypes; |
| 14 | 15 |
import eu.dnetlib.enabling.tools.JaxwsServiceResolverImpl; |
| 15 | 16 |
import eu.dnetlib.iis.common.WorkflowRuntimeParameters; |
| 16 |
import eu.dnetlib.iis.core.java.HadoopContext; |
|
| 17 | 17 |
import eu.dnetlib.iis.core.java.PortBindings; |
| 18 | 18 |
import eu.dnetlib.iis.core.java.Process; |
| 19 | 19 |
import eu.dnetlib.iis.core.java.ProcessUtils; |
| ... | ... | |
| 44 | 44 |
} |
| 45 | 45 |
|
| 46 | 46 |
@Override |
| 47 |
public void run(PortBindings portBindings, HadoopContext context,
|
|
| 47 |
public void run(PortBindings portBindings, Configuration conf,
|
|
| 48 | 48 |
Map<String, String> parameters) throws Exception {
|
| 49 | 49 |
String actionManagerLocation = ProcessUtils.getParameterValue( |
| 50 | 50 |
PARAM_ACTION_MANAGER_SERVICE_LOCATION, |
| 51 |
context.getConfiguration(), parameters);
|
|
| 51 |
conf, parameters);
|
|
| 52 | 52 |
String actionSetId = ProcessUtils.getParameterValue( |
| 53 | 53 |
PARAM_ACTION_SET_ID, |
| 54 |
context.getConfiguration(), parameters);
|
|
| 54 |
conf, parameters);
|
|
| 55 | 55 |
if (actionManagerLocation!=null |
| 56 | 56 |
&& !WorkflowRuntimeParameters.UNDEFINED_NONEMPTY_VALUE.equals(actionManagerLocation) |
| 57 | 57 |
&& actionSetId!=null) {
|
Also available in: Unified diff
Removing usage of working_dir from Java workflow node.