code formatting

dhp-workflows/dhp-aggregation/src/main/java/eu/dnetlib/dhp/actionmanager/opencitations/CreateActionSetSparkJob.java

@@ -65,10 +65,10 @@ public class CreateActionSetSparkJob implements Serializable {
 		final String outputPath = parser.get("outputPath");
 		log.info("outputPath {}", outputPath);
 
-		final boolean shouldDuplicateRels =
-				Optional.ofNullable(parser.get("shouldDuplicateRels"))
-				.map(Boolean::valueOf)
-				.orElse(Boolean.FALSE);
+		final boolean shouldDuplicateRels = Optional
+			.ofNullable(parser.get("shouldDuplicateRels"))
+			.map(Boolean::valueOf)
+			.orElse(Boolean.FALSE);
 
 		SparkConf conf = new SparkConf();
 		runWithSparkSession(

dhp-workflows/dhp-aggregation/src/test/java/eu/dnetlib/dhp/actionmanager/opencitations/CreateOpenCitationsASTest.java

@@ -84,8 +84,8 @@ public class CreateOpenCitationsASTest {
 				new String[] {
 					"-isSparkSessionManaged",
 					Boolean.FALSE.toString(),
-						"-shouldDuplicateRels",
-						Boolean.TRUE.toString(),
+					"-shouldDuplicateRels",
+					Boolean.TRUE.toString(),
 					"-inputPath",
 					inputPath,
 					"-outputPath",
@@ -101,7 +101,7 @@ public class CreateOpenCitationsASTest {
 
 		assertEquals(60, tmp.count());
 
-	//	tmp.foreach(r -> System.out.println(OBJECT_MAPPER.writeValueAsString(r)));
+		// tmp.foreach(r -> System.out.println(OBJECT_MAPPER.writeValueAsString(r)));
 
 	}
 
@@ -109,31 +109,31 @@ public class CreateOpenCitationsASTest {
 	void testNumberofRelations2() throws Exception {
 
 		String inputPath = getClass()
-				.getResource(
-						"/eu/dnetlib/dhp/actionmanager/opencitations/inputFiles")
-				.getPath();
+			.getResource(
+				"/eu/dnetlib/dhp/actionmanager/opencitations/inputFiles")
+			.getPath();
 
 		CreateActionSetSparkJob
-				.main(
-						new String[] {
-								"-isSparkSessionManaged",
-								Boolean.FALSE.toString(),
-								"-inputPath",
-								inputPath,
-								"-outputPath",
-								workingDir.toString() + "/actionSet"
-						});
+			.main(
+				new String[] {
+					"-isSparkSessionManaged",
+					Boolean.FALSE.toString(),
+					"-inputPath",
+					inputPath,
+					"-outputPath",
+					workingDir.toString() + "/actionSet"
+				});
 
 		final JavaSparkContext sc = new JavaSparkContext(spark.sparkContext());
 
 		JavaRDD<Relation> tmp = sc
-				.sequenceFile(workingDir.toString() + "/actionSet", Text.class, Text.class)
-				.map(value -> OBJECT_MAPPER.readValue(value._2().toString(), AtomicAction.class))
-				.map(aa -> ((Relation) aa.getPayload()));
+			.sequenceFile(workingDir.toString() + "/actionSet", Text.class, Text.class)
+			.map(value -> OBJECT_MAPPER.readValue(value._2().toString(), AtomicAction.class))
+			.map(aa -> ((Relation) aa.getPayload()));
 
 		assertEquals(44, tmp.count());
 
-		//	tmp.foreach(r -> System.out.println(OBJECT_MAPPER.writeValueAsString(r)));
+		// tmp.foreach(r -> System.out.println(OBJECT_MAPPER.writeValueAsString(r)));
 
 	}