Revision 60365
Added by Claudio Atzori almost 4 years ago
| modules/dnet-openaireplus-workflows/trunk/src/main/java/eu/dnetlib/msro/openaireplus/workflows/nodes/dhp/PrepareEnvCollectHadoopJobNode.java | ||
|---|---|---|
| 68 | 68 |
@Value("${dnet.openaire.dhp.collection.app.path}")
|
| 69 | 69 |
private String oozieWfPath; |
| 70 | 70 |
|
| 71 |
@Value("${dnet.openaire.dhp.dnetMessageManagerURL}")
|
|
| 72 |
private String dnetMessageManagerURL; |
|
| 73 |
|
|
| 71 | 74 |
@Override |
| 72 | 75 |
protected String execute(final NodeToken token) throws Exception {
|
| 73 | 76 |
|
| ... | ... | |
| 98 | 101 |
token.getEnv().setAttribute("collectionMode", getCollectionMode());
|
| 99 | 102 |
token.getEnv().setAttribute("metadataEncoding", getMetadataEncoding());
|
| 100 | 103 |
token.getEnv().setAttribute("oozieWfPath", getOozieWfPath());
|
| 104 |
token.getEnv().setAttribute("dnetMessageManagerURL", getDnetMessageManagerURL());
|
|
| 101 | 105 |
|
| 102 | 106 |
final ApiDescriptor api = opt.get(); |
| 103 | 107 |
if ("INCREMENTAL".equals(getCollectionMode())) {
|
| ... | ... | |
| 224 | 228 |
public void setFromDateOverride(String fromDateOverride) {
|
| 225 | 229 |
this.fromDateOverride = fromDateOverride; |
| 226 | 230 |
} |
| 231 |
|
|
| 232 |
public String getDnetMessageManagerURL() {
|
|
| 233 |
return dnetMessageManagerURL; |
|
| 234 |
} |
|
| 235 |
|
|
| 236 |
public void setDnetMessageManagerURL(String dnetMessageManagerURL) {
|
|
| 237 |
this.dnetMessageManagerURL = dnetMessageManagerURL; |
|
| 238 |
} |
|
| 227 | 239 |
} |
| modules/dnet-openaireplus-workflows/trunk/src/main/resources/eu/dnetlib/msro/openaireplus/applicationContext-msro-openaireplus.properties | ||
|---|---|---|
| 96 | 96 |
|
| 97 | 97 |
dnet.openaire.dhp.collection.app.path = /user/dnet.dev/lib/collection/oozie_app |
| 98 | 98 |
dnet.openaire.dhp.transformation.app.path = /user/dnet.dev/lib/transformation/oozie_app |
| 99 |
|
|
| 100 |
dnet.openaire.dhp.dnetMessageManagerURL = https://${container.hostname}:${container.port}/${container.context}/mvc/dhp/message
|
|
| 99 | 101 |
|
Also available in: Unified diff
updated hadoop-specific aggregation workflows