From 550cb21c23559e7025b28be6483244cd04aef21c Mon Sep 17 00:00:00 2001
From: "miriam.baglioni" <miriam.baglioni@isti.cnr.it>
Date: Fri, 28 Feb 2020 18:24:39 +0100
Subject: [PATCH] None

---
 .../SparkResultToProjectThroughSemRelJob.java             | 8 +++-----
 1 file changed, 3 insertions(+), 5 deletions(-)

diff --git a/dhp-workflows/dhp-propagation/src/main/java/eu/dnetlib/dhp/projecttoresult/SparkResultToProjectThroughSemRelJob.java b/dhp-workflows/dhp-propagation/src/main/java/eu/dnetlib/dhp/projecttoresult/SparkResultToProjectThroughSemRelJob.java
index 1d99b3ec8d..1798aa67a0 100644
--- a/dhp-workflows/dhp-propagation/src/main/java/eu/dnetlib/dhp/projecttoresult/SparkResultToProjectThroughSemRelJob.java
+++ b/dhp-workflows/dhp-propagation/src/main/java/eu/dnetlib/dhp/projecttoresult/SparkResultToProjectThroughSemRelJob.java
@@ -48,11 +48,7 @@ public class SparkResultToProjectThroughSemRelJob {
         JavaRDD<Relation> relations = sc.sequenceFile(inputPath + "/relation", Text.class, Text.class)
                 .map(item -> new ObjectMapper().readValue(item._2().toString(), Relation.class)).cache();
 
-        JavaPairRDD<String, TypedRow> result_result = relations
-                .filter(r -> !r.getDataInfo().getDeletedbyinference())
-                .filter(r -> allowedsemrel.contains(r.getRelClass()) && RELATION_RESULTRESULT_REL_TYPE.equals(r.getRelType()))
-                .map(r -> new TypedRow().setSourceId(r.getSource()).setTargetId(r.getTarget()))
-                .mapToPair(toPair());
+        JavaPairRDD<String, TypedRow> result_result = getResultResultSemRel(allowedsemrel, relations);
 
         JavaPairRDD<String, TypedRow> result_project = relations
                 .filter(r -> !r.getDataInfo().getDeletedbyinference())
@@ -117,4 +113,6 @@ public class SparkResultToProjectThroughSemRelJob {
     }
 
 
+
+
 }