From 5a32bb9578d437e669539d07c66eb84c0ddc58c5 Mon Sep 17 00:00:00 2001
From: "miriam.baglioni" <miriam.baglioni@isti.cnr.it>
Date: Wed, 13 Mar 2024 09:36:18 +0100
Subject: [PATCH] [OC New] last fix

---
 .../actionmanager/opencitations/MapOCIdsInPids.java   | 11 +----------
 1 file changed, 1 insertion(+), 10 deletions(-)

diff --git a/dhp-workflows/dhp-aggregation/src/main/java/eu/dnetlib/dhp/actionmanager/opencitations/MapOCIdsInPids.java b/dhp-workflows/dhp-aggregation/src/main/java/eu/dnetlib/dhp/actionmanager/opencitations/MapOCIdsInPids.java
index d4fc33f01..f7de4ac08 100644
--- a/dhp-workflows/dhp-aggregation/src/main/java/eu/dnetlib/dhp/actionmanager/opencitations/MapOCIdsInPids.java
+++ b/dhp-workflows/dhp-aggregation/src/main/java/eu/dnetlib/dhp/actionmanager/opencitations/MapOCIdsInPids.java
@@ -166,15 +166,6 @@ public class MapOCIdsInPids implements Serializable {
 			.option("compression", "gzip")
 			.json(outputPath);
 
-		mappedCitingDataset
-			.joinWith(correspondenceData, mappedCitingDataset.col("cited").equalTo(correspondenceData.col("_1")))
-			.map((MapFunction<Tuple2<COCI, Tuple2<String, String>>, COCI>) t2 -> {
-				String correspondent = t2._2()._2();
-				t2._1().setCited_pid(correspondent.substring(0, correspondent.indexOf(":")));
-				t2._1().setCited(correspondent.substring(correspondent.indexOf(":") + 1));
-				return t2._1();
-			}, Encoders.bean(COCI.class))
-			.foreach((ForeachFunction<COCI>) c -> System.out.println(OBJECT_MAPPER.writeValueAsString(c)));
-	}
+			}
 
 }