Revision 60320
Added by Claudio Atzori about 3 years ago
| modules/dnet-openaireplus-workflows/trunk/src/main/java/eu/dnetlib/msro/openaireplus/workflows/nodes/dhp/CreateMDStoreHadoopJobNode.java | ||
|---|---|---|
| 40 | 40 |
params.put("interpretation", getInterpretation());
|
| 41 | 41 |
|
| 42 | 42 |
final URI uri = UriComponentsBuilder.fromUriString(url) |
| 43 |
.queryParam("dsName", token.getEnv().getAttribute(WorkflowsConstants.DATAPROVIDER_NAME))
|
|
| 44 |
.queryParam("dsId", token.getEnv().getAttribute(WorkflowsConstants.DATAPROVIDER_ID))
|
|
| 45 |
.queryParam("apiId", token.getEnv().getAttribute(WorkflowsConstants.DATAPROVIDER_INTERFACE))
|
|
| 43 |
.queryParam("dsName", token.getFullEnv().getAttribute(WorkflowsConstants.DATAPROVIDER_NAME))
|
|
| 44 |
.queryParam("dsId", token.getFullEnv().getAttribute(WorkflowsConstants.DATAPROVIDER_ID))
|
|
| 45 |
.queryParam("apiId", token.getFullEnv().getAttribute(WorkflowsConstants.DATAPROVIDER_INTERFACE))
|
|
| 46 | 46 |
.buildAndExpand(params) |
| 47 | 47 |
.toUri(); |
| 48 | 48 |
|
Also available in: Unified diff
updated hadoop-specific aggregation workflows