Revision 60318
Added by Claudio Atzori about 3 years ago
PrepareEnvCollectHadoopJobNode.java | ||
---|---|---|
19 | 19 |
import eu.dnetlib.enabling.datasources.common.LocalDatasourceManager; |
20 | 20 |
import eu.dnetlib.msro.workflows.nodes.SimpleJobNode; |
21 | 21 |
import eu.dnetlib.msro.workflows.util.WorkflowsConstants; |
22 |
import org.springframework.beans.factory.annotation.Value; |
|
22 | 23 |
|
23 | 24 |
public class PrepareEnvCollectHadoopJobNode extends SimpleJobNode { |
24 | 25 |
|
... | ... | |
38 | 39 |
*/ |
39 | 40 |
private String collectionMode; |
40 | 41 |
|
42 |
@Value("${dnet.openaire.dhp.collection.app.path}") |
|
43 |
private String oozieWfPath; |
|
44 |
|
|
41 | 45 |
@Override |
42 | 46 |
protected String execute(final NodeToken token) throws Exception { |
43 | 47 |
|
... | ... | |
70 | 74 |
if (opt.isPresent()) { |
71 | 75 |
token.getEnv().setAttribute("mdId", getMdId()); |
72 | 76 |
token.getEnv().setAttribute("collectionMode", getCollectionMode()); |
77 |
token.getEnv().setAttribute("oozieWfPath", getOozieWfPath()); |
|
73 | 78 |
|
74 | 79 |
final ApiDescriptor api = opt.get(); |
75 | 80 |
token.getEnv().setAttribute("apiDescription", new Gson().toJson(api)); |
... | ... | |
117 | 122 |
public void setCollectionMode(String collectionMode) { |
118 | 123 |
this.collectionMode = collectionMode; |
119 | 124 |
} |
125 |
|
|
126 |
public String getOozieWfPath() { |
|
127 |
return oozieWfPath; |
|
128 |
} |
|
129 |
|
|
130 |
public void setOozieWfPath(String oozieWfPath) { |
|
131 |
this.oozieWfPath = oozieWfPath; |
|
132 |
} |
|
120 | 133 |
} |
Also available in: Unified diff
updated hadoop-specific aggregation workflows