From d9993ee5a250b3e3320d9c63c2a6066d1079e748 Mon Sep 17 00:00:00 2001 From: "miriam.baglioni" Date: Mon, 5 Jun 2023 08:14:22 +0200 Subject: [PATCH] added workaround to include B2FIND --- .../dhp/oa/graph/dump/eosc/SelectEoscResultsJobStep1.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/dump/src/main/java/eu/dnetlib/dhp/oa/graph/dump/eosc/SelectEoscResultsJobStep1.java b/dump/src/main/java/eu/dnetlib/dhp/oa/graph/dump/eosc/SelectEoscResultsJobStep1.java index a6eab77..dcf5cec 100644 --- a/dump/src/main/java/eu/dnetlib/dhp/oa/graph/dump/eosc/SelectEoscResultsJobStep1.java +++ b/dump/src/main/java/eu/dnetlib/dhp/oa/graph/dump/eosc/SelectEoscResultsJobStep1.java @@ -77,7 +77,10 @@ public class SelectEoscResultsJobStep1 implements Serializable { .readPath(spark, inputPath, inputClazz) .filter( (FilterFunction) r -> !r.getDataInfo().getDeletedbyinference() && !r.getDataInfo().getInvisible() - && r.getContext().stream().anyMatch(c -> c.getId().equals("eosc"))) + && (r.getContext().stream().anyMatch(c -> c.getId().equals("eosc")) || r + .getCollectedfrom() + .stream() + .anyMatch(cf -> cf.getValue().equalsIgnoreCase("B2FIND")))) .map( (MapFunction) r -> (Result) ResultMapper