From 13f30664ea02578c9d9f8803ec88399c700c6132 Mon Sep 17 00:00:00 2001
From: "miriam.baglioni" <miriam.baglioni@isti.cnr.it>
Date: Thu, 30 Apr 2020 15:23:49 +0200
Subject: [PATCH] minor

---
 ...ResultToCommunityFromOrganizationJob2.java |  2 +-
 ...rkResultToOrganizationFromIstRepoJob2.java | 37 +++++++++----------
 2 files changed, 18 insertions(+), 21 deletions(-)

diff --git a/dhp-workflows/dhp-propagation/src/main/java/eu/dnetlib/dhp/resulttocommunityfromorganization/SparkResultToCommunityFromOrganizationJob2.java b/dhp-workflows/dhp-propagation/src/main/java/eu/dnetlib/dhp/resulttocommunityfromorganization/SparkResultToCommunityFromOrganizationJob2.java
index 30908012b..7cc3d6d59 100644
--- a/dhp-workflows/dhp-propagation/src/main/java/eu/dnetlib/dhp/resulttocommunityfromorganization/SparkResultToCommunityFromOrganizationJob2.java
+++ b/dhp-workflows/dhp-propagation/src/main/java/eu/dnetlib/dhp/resulttocommunityfromorganization/SparkResultToCommunityFromOrganizationJob2.java
@@ -70,7 +70,7 @@ public class SparkResultToCommunityFromOrganizationJob2 {
 				if (isTest(parser)) {
 					removeOutputDir(spark, outputPath);
 				}
-				if(saveGraph)
+				if (saveGraph)
 					execPropagation(spark, inputPath, outputPath, resultClazz, possibleupdatespath);
 			});
 	}
diff --git a/dhp-workflows/dhp-propagation/src/main/java/eu/dnetlib/dhp/resulttoorganizationfrominstrepo/SparkResultToOrganizationFromIstRepoJob2.java b/dhp-workflows/dhp-propagation/src/main/java/eu/dnetlib/dhp/resulttoorganizationfrominstrepo/SparkResultToOrganizationFromIstRepoJob2.java
index b69158c87..72c75e8a6 100644
--- a/dhp-workflows/dhp-propagation/src/main/java/eu/dnetlib/dhp/resulttoorganizationfrominstrepo/SparkResultToOrganizationFromIstRepoJob2.java
+++ b/dhp-workflows/dhp-propagation/src/main/java/eu/dnetlib/dhp/resulttoorganizationfrominstrepo/SparkResultToOrganizationFromIstRepoJob2.java
@@ -58,8 +58,6 @@ public class SparkResultToOrganizationFromIstRepoJob2 {
 		final String resultClassName = parser.get("resultTableName");
 		log.info("resultTableName: {}", resultClassName);
 
-
-
 		final Boolean saveGraph = Optional
 			.ofNullable(parser.get("saveGraph"))
 			.map(Boolean::valueOf)
@@ -78,7 +76,7 @@ public class SparkResultToOrganizationFromIstRepoJob2 {
 				if (isTest(parser)) {
 					removeOutputDir(spark, outputPath);
 				}
-				if(saveGraph)
+				if (saveGraph)
 					execPropagation(
 						spark,
 						datasourceorganization,
@@ -86,7 +84,7 @@ public class SparkResultToOrganizationFromIstRepoJob2 {
 						inputPath,
 						outputPath,
 						resultClazz);
-				});
+			});
 	}
 
 	private static void execPropagation(
@@ -112,22 +110,21 @@ public class SparkResultToOrganizationFromIstRepoJob2 {
 			broadcast_datasourceorganizationassoc)
 				.as(Encoders.bean(ResultOrganizationSet.class));
 
-
-			getNewRelations(
-				spark
-					.read()
-					.textFile(alreadylinked)
-					.map(
-						value -> OBJECT_MAPPER
-							.readValue(
-								value, ResultOrganizationSet.class),
-						Encoders.bean(ResultOrganizationSet.class)),
-				potentialUpdates)
-					.toJSON()
-					.write()
-					.mode(SaveMode.Append)
-					.option("compression", "gzip")
-					.text(outputPath);
+		getNewRelations(
+			spark
+				.read()
+				.textFile(alreadylinked)
+				.map(
+					value -> OBJECT_MAPPER
+						.readValue(
+							value, ResultOrganizationSet.class),
+					Encoders.bean(ResultOrganizationSet.class)),
+			potentialUpdates)
+				.toJSON()
+				.write()
+				.mode(SaveMode.Append)
+				.option("compression", "gzip")
+				.text(outputPath);
 
 	}