Revision 60321
Added by Claudio Atzori about 3 years ago
PrepareEnvCollectHadoopJobNode.java | ||
---|---|---|
39 | 39 |
*/ |
40 | 40 |
private String collectionMode; |
41 | 41 |
|
42 |
/** |
|
43 |
* XML | JSON, default = XML |
|
44 |
*/ |
|
45 |
private String metadataEncoding = "XML"; |
|
46 |
|
|
42 | 47 |
@Value("${dnet.openaire.dhp.collection.app.path}") |
43 | 48 |
private String oozieWfPath; |
44 | 49 |
|
... | ... | |
74 | 79 |
if (opt.isPresent()) { |
75 | 80 |
token.getEnv().setAttribute("mdId", getMdId()); |
76 | 81 |
token.getEnv().setAttribute("collectionMode", getCollectionMode()); |
82 |
token.getEnv().setAttribute("metadataEncoding", getMetadataEncoding()); |
|
77 | 83 |
token.getEnv().setAttribute("oozieWfPath", getOozieWfPath()); |
78 | 84 |
|
79 | 85 |
final ApiDescriptor api = opt.get(); |
... | ... | |
130 | 136 |
public void setOozieWfPath(String oozieWfPath) { |
131 | 137 |
this.oozieWfPath = oozieWfPath; |
132 | 138 |
} |
139 |
|
|
140 |
public String getMetadataEncoding() { |
|
141 |
return metadataEncoding; |
|
142 |
} |
|
143 |
|
|
144 |
public void setMetadataEncoding(String metadataEncoding) { |
|
145 |
this.metadataEncoding = metadataEncoding; |
|
146 |
} |
|
133 | 147 |
} |
Also available in: Unified diff
updated hadoop-specific aggregation workflows