Revision 58659
Added by Claudio Atzori almost 4 years ago
modules/dnet-mapreduce-jobs/trunk/src/main/java/eu/dnetlib/data/mapreduce/hbase/dataexport/ProtoConverter.java | ||
---|---|---|
55 | 55 |
case result: |
56 | 56 |
final Result r = convertResult(oaf); |
57 | 57 |
r.setInstance(convertInstances(oaf)); |
58 |
r.setExternalReference(convertExternalRefs(oaf)); |
|
58 | 59 |
return r; |
59 | 60 |
case project: |
60 | 61 |
return convertProject(oaf); |
... | ... | |
67 | 68 |
} |
68 | 69 |
} |
69 | 70 |
|
71 |
private static List<ExternalReference> convertExternalRefs(OafProtos.Oaf oaf) { |
|
72 |
ResultProtos.Result r = oaf.getEntity().getResult(); |
|
73 |
if (r.getExternalReferenceCount() > 0) { |
|
74 |
return r.getExternalReferenceList() |
|
75 |
.stream() |
|
76 |
.map(e -> convertExtRef(e)) |
|
77 |
.collect(Collectors.toList()); |
|
78 |
} |
|
79 |
return Lists.newArrayList(); |
|
80 |
} |
|
81 |
|
|
82 |
private static ExternalReference convertExtRef(ResultProtos.Result.ExternalReference e) { |
|
83 |
ExternalReference ex = new ExternalReference(); |
|
84 |
ex.setUrl(e.getUrl()); |
|
85 |
ex.setSitename(e.getSitename()); |
|
86 |
ex.setRefidentifier(e.getRefidentifier()); |
|
87 |
ex.setQuery(e.getQuery()); |
|
88 |
ex.setQualifier(mapQualifier(e.getQualifier())); |
|
89 |
ex.setLabel(e.getLabel()); |
|
90 |
ex.setDescription(e.getDescription()); |
|
91 |
ex.setDataInfo(ex.getDataInfo()); |
|
92 |
return ex; |
|
93 |
} |
|
94 |
|
|
70 | 95 |
private static List<Instance> convertInstances(OafProtos.Oaf oaf) { |
71 | 96 |
|
72 | 97 |
final ResultProtos.Result r = oaf.getEntity().getResult(); |
Also available in: Unified diff
added mapping for externalreferences