From e0a0dddfac3a1f60fdf37a15a43bbda695b3ee28 Mon Sep 17 00:00:00 2001 From: "miriam.baglioni" Date: Mon, 29 Apr 2024 18:30:51 +0200 Subject: [PATCH] remove from the set of relation to be included in the dump also those with relType resultService. It is not possible to extend the removeSet parameter because the relClass is IsRelatedTo --- .../eu/dnetlib/dhp/oa/graph/dump/subset/SparkSelectSubset.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/dump/src/main/java/eu/dnetlib/dhp/oa/graph/dump/subset/SparkSelectSubset.java b/dump/src/main/java/eu/dnetlib/dhp/oa/graph/dump/subset/SparkSelectSubset.java index 5c02498..ec729b8 100644 --- a/dump/src/main/java/eu/dnetlib/dhp/oa/graph/dump/subset/SparkSelectSubset.java +++ b/dump/src/main/java/eu/dnetlib/dhp/oa/graph/dump/subset/SparkSelectSubset.java @@ -82,7 +82,8 @@ public class SparkSelectSubset implements Serializable { .readPath(spark, inputPath + "/relation", Relation.class) .filter( (FilterFunction) r -> !r.getDataInfo().getDeletedbyinference() - && !removeSet.contains(r.getRelClass())); + && !removeSet.contains(r.getRelClass()) && + !r.getRelType().equals("resultService")); Dataset resultIds = Utils .readPath(spark, outputPath + "/original/publication", Publication.class)