From 686f407bcd72f2b3cc31ec2e5dfd6ac8f5df3bcd Mon Sep 17 00:00:00 2001
From: "miriam.baglioni" <miriam.baglioni@isti.cnr.it>
Date: Mon, 7 Nov 2022 17:55:51 +0100
Subject: [PATCH] [EOSC DUMP] removed not needed parameters

---
 .../eosc/ExtendEoscResultWithOrganizationStep2.java   | 11 +++--------
 1 file changed, 3 insertions(+), 8 deletions(-)

diff --git a/dump/src/main/java/eu/dnetlib/dhp/oa/graph/dump/eosc/ExtendEoscResultWithOrganizationStep2.java b/dump/src/main/java/eu/dnetlib/dhp/oa/graph/dump/eosc/ExtendEoscResultWithOrganizationStep2.java
index c99bb26..2df780f 100644
--- a/dump/src/main/java/eu/dnetlib/dhp/oa/graph/dump/eosc/ExtendEoscResultWithOrganizationStep2.java
+++ b/dump/src/main/java/eu/dnetlib/dhp/oa/graph/dump/eosc/ExtendEoscResultWithOrganizationStep2.java
@@ -61,11 +61,6 @@ public class ExtendEoscResultWithOrganizationStep2 implements Serializable {
 		final String outputPath = parser.get("outputPath");
 		log.info("outputPath: {}", outputPath);
 
-		final String resultClassName = parser.get("resultTableName");
-		log.info("resultTableName: {}", resultClassName);
-
-		Class<? extends Result> inputClazz = (Class<? extends Result>) Class.forName(resultClassName);
-
 		SparkConf conf = new SparkConf();
 
 		runWithSparkSession(
@@ -73,12 +68,12 @@ public class ExtendEoscResultWithOrganizationStep2 implements Serializable {
 			isSparkSessionManaged,
 			spark -> {
 				Utils.removeOutputDir(spark, outputPath);
-				addOrganizations(spark, inputPath, outputPath, resultPath, inputClazz);
+				addOrganizations(spark, inputPath, outputPath, resultPath);
 			});
 	}
 
-	private static <R extends Result> void addOrganizations(SparkSession spark, String inputPath, String outputPath,
-		String resultPath, Class<R> inputClazz) {
+	private static void addOrganizations(SparkSession spark, String inputPath, String outputPath,
+		String resultPath) {
 		Dataset<EoscResult> results = Utils
 			.readPath(spark, resultPath, EoscResult.class);