forked from D-Net/dnet-hadoop
hostedby patching to work with the updated Crossref contents
This commit is contained in:
parent
efc1632e16
commit
576efc1857
|
@ -27,10 +27,12 @@ object SparkApplyHostedByMapToResult {
|
|||
val inst: Instance = i.head
|
||||
patchInstance(p, ei, inst)
|
||||
|
||||
} else if (i.size == 2) {
|
||||
if (i.map(ii => ii.getCollectedfrom.getValue).contains("UnpayWall")) {
|
||||
val inst: Instance = i.filter(ii => "Crossref".equals(ii.getCollectedfrom.getValue)).head
|
||||
patchInstance(p, ei, inst)
|
||||
} else {
|
||||
val cf = i.map(ii => ii.getCollectedfrom.getValue)
|
||||
if (cf.contains("Crossref")) {
|
||||
i.foreach(ii => {
|
||||
patchInstance(p, ei, ii)
|
||||
})
|
||||
}
|
||||
}
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue