Revision 48145
Added by Claudio Atzori over 6 years ago
OpenAireEventPayloadFactory.java | ||
---|---|---|
1 | 1 |
package eu.dnetlib.data.mapreduce.hbase.broker.mapping; |
2 | 2 |
|
3 |
import static eu.dnetlib.data.mapreduce.util.OafHbaseUtils.getKey; |
|
4 |
import static eu.dnetlib.data.mapreduce.util.OafHbaseUtils.getValue; |
|
5 |
import static eu.dnetlib.data.mapreduce.util.OafHbaseUtils.listValues; |
|
6 |
|
|
7 |
import org.dom4j.DocumentException; |
|
8 |
|
|
9 | 3 |
import com.google.common.collect.Iterables; |
10 |
|
|
11 |
import eu.dnetlib.broker.objects.Journal; |
|
4 |
import eu.dnetlib.broker.objects.Instance; |
|
12 | 5 |
import eu.dnetlib.broker.objects.OpenAireEventPayload; |
13 | 6 |
import eu.dnetlib.broker.objects.Provenance; |
14 | 7 |
import eu.dnetlib.broker.objects.Publication; |
15 | 8 |
import eu.dnetlib.data.proto.OafProtos.OafEntity; |
16 | 9 |
import eu.dnetlib.data.proto.ResultProtos.Result; |
17 |
import eu.dnetlib.data.proto.ResultProtos.Result.Instance; |
|
18 | 10 |
|
11 |
import static eu.dnetlib.data.mapreduce.util.OafHbaseUtils.*; |
|
12 |
|
|
19 | 13 |
/** |
20 | 14 |
* Created by claudio on 11/07/16. |
21 | 15 |
*/ |
... | ... | |
25 | 19 |
final OafEntity source, |
26 | 20 |
final float trust) { |
27 | 21 |
|
22 |
return fromOAF(oaf, trust, new Provenance() |
|
23 |
.setRepositoryName(getValue(source.getCollectedfromList())) |
|
24 |
.setUrl(Iterables.getFirst(mapInstances(oaf.getResult().getInstanceList()), new Instance()).getUrl()) |
|
25 |
.setId(getValue(source.getOriginalIdList()))); |
|
26 |
} |
|
27 |
|
|
28 |
public static OpenAireEventPayload fromOAF(final OafEntity oaf, |
|
29 |
final float trust, final Provenance provenance) { |
|
30 |
|
|
28 | 31 |
final Result.Metadata m = oaf.getResult().getMetadata(); |
29 | 32 |
final Publication p = new Publication() |
30 | 33 |
.setOriginalId(getValue(oaf.getOriginalIdList())) |
... | ... | |
37 | 40 |
.setPublisher(getValue(m.getPublisher())) |
38 | 41 |
.setEmbargoenddate(getValue(m.getEmbargoenddate())) |
39 | 42 |
.setContributor(listValues(m.getContributorList())) |
40 |
.setJournal(new Journal() |
|
41 |
.setName(m.getJournal().getName()) |
|
42 |
.setIssn(m.getJournal().getIssnPrinted()) |
|
43 |
.setEissn(m.getJournal().getIssnOnline()) |
|
44 |
.setLissn(m.getJournal().getIssnLinking())) |
|
43 |
.setJournal(mapJournal(m.getJournal())) |
|
45 | 44 |
.setCollectedFrom(listValues(oaf.getCollectedfromList())) |
46 | 45 |
.setPids(mapPids(oaf.getPidList())) |
47 | 46 |
.setInstances(mapInstances(oaf.getResult().getInstanceList())) |
48 | 47 |
.setExternalReferences(mapExternalRefs(oaf.getResult().getExternalReferenceList())) |
49 | 48 |
.setProjects(mapRelatedProjects(oaf)); |
50 | 49 |
|
51 |
final OpenAireEventPayload ep = new OpenAireEventPayload(); |
|
52 |
|
|
53 |
final Instance instance = Iterables.getFirst(source.getResult().getInstanceList(), Instance.newBuilder().build()); |
|
54 |
|
|
55 |
ep.setPublication(p).setHighlight(new Publication()).setProvenance(new Provenance().setRepositoryName(getValue(source.getCollectedfromList())) |
|
56 |
.setUrl(getValue(instance.getUrlList())).setId(getValue(source.getOriginalIdList()))).setTrust(trust); |
|
57 |
|
|
58 |
return ep; |
|
50 |
return new OpenAireEventPayload() |
|
51 |
.setPublication(p) |
|
52 |
.setHighlight(new Publication()) |
|
53 |
.setProvenance(provenance) |
|
54 |
.setTrust(trust); |
|
59 | 55 |
} |
60 | 56 |
|
61 | 57 |
} |
Also available in: Unified diff
integrated latest changes from dnet40