Revision 55476
Added by Claudio Atzori almost 5 years ago
| modules/dnet-openaireplus-workflows/branches/dnet-hadoop/src/main/java/eu/dnetlib/msro/openaireplus/workflows/nodes/hadoop/PrepareEnvCollectHadoopJobNode.java | ||
|---|---|---|
| 1 | 1 |
package eu.dnetlib.msro.openaireplus.workflows.nodes.hadoop; |
| 2 | 2 |
|
| 3 |
import java.util.Map; |
|
| 3 | 4 |
import java.util.Optional; |
| 4 | 5 |
import java.util.stream.Collectors; |
| 5 | 6 |
|
| ... | ... | |
| 73 | 74 |
token.getEnv().setAttribute("timestamp", ""+System.currentTimeMillis());
|
| 74 | 75 |
token.getEnv().setAttribute("identifierPath",api.getParams().get("metadata_identifier_path"));
|
| 75 | 76 |
token.getEnv().setAttribute("workflowId",token.getProcess().getEnv().getAttribute("system:processId"));
|
| 77 |
|
|
| 78 |
token.getEnv().setAttribute(WorkflowsConstants.DATAPROVIDER_INTERFACE_BASEURL, api.getBaseUrl()); |
|
| 79 |
token.getEnv().setAttribute(WorkflowsConstants.DATAPROVIDER_PREFIX + "protocol", api.getProtocol()); |
|
| 80 |
final Map<String, String> params = api.getParams(); |
|
| 81 |
if (params != null) {
|
|
| 82 |
for(Map.Entry<String, String> e : params.entrySet()) {
|
|
| 83 |
token.getEnv().setAttribute(WorkflowsConstants.DATAPROVIDER_PREFIX + e.getKey(), e.getValue()); |
|
| 84 |
} |
|
| 85 |
} |
|
| 86 |
|
|
| 76 | 87 |
return Arc.DEFAULT_ARC; |
| 77 | 88 |
} else {
|
| 78 | 89 |
return "abort"; |
Also available in: Unified diff
Save interface descriptor data in the aggregation workflow logger entries #4470