Revision 57633
Added by Claudio Atzori almost 5 years ago
| modules/dnet-mapreduce-jobs/trunk/src/main/java/eu/dnetlib/data/mapreduce/hbase/broker/enrich/EnrichmentReducer.java | ||
|---|---|---|
| 72 | 72 |
|
| 73 | 73 |
final float trust = scale(similarity); |
| 74 | 74 |
if (!DedupUtils.isRoot(currentId) && !DedupUtils.isRoot(otherId)) {
|
| 75 |
//events.addAll(PIDEventFactory.process(current, other, trust));
|
|
| 76 |
//events.addAll(OAVersionEventFactory.process(current, other, trust, untrustedOaDsList));
|
|
| 77 |
//events.addAll(AbstractEventFactory.process(current, other, trust));
|
|
| 78 |
//events.addAll(PublicationDateEventFactory.process(current, other, trust));
|
|
| 79 |
events.addAll(OrcidEventFactory.process(current, other, trust)); |
|
| 75 |
events.addAll(PIDEventFactory.process(current, other, trust)); |
|
| 76 |
events.addAll(OAVersionEventFactory.process(current, other, trust, untrustedOaDsList)); |
|
| 77 |
events.addAll(AbstractEventFactory.process(current, other, trust)); |
|
| 78 |
events.addAll(PublicationDateEventFactory.process(current, other, trust)); |
|
| 79 |
//events.addAll(OrcidEventFactory.process(current, other, trust));
|
|
| 80 | 80 |
} |
| 81 | 81 |
|
| 82 |
//events.addAll(SubjectEventFactory.process(context, current, other, trust));
|
|
| 82 |
events.addAll(SubjectEventFactory.process(context, current, other, trust)); |
|
| 83 | 83 |
} else {
|
| 84 | 84 |
context.getCounter(counterGroup(), "d < " + dedupConf.getWf().getThreshold()).increment(1); |
| 85 | 85 |
} |
| 86 | 86 |
|
| 87 | 87 |
} else if (oafList.size() == 1) {
|
| 88 |
//events.addAll(SubjectEventFactory.process(context, current));
|
|
| 88 |
events.addAll(SubjectEventFactory.process(context, current)); |
|
| 89 | 89 |
} |
| 90 | 90 |
} |
| 91 | 91 |
emit(events, context); |
Also available in: Unified diff
ORCID events are not yet ready for production