From 278fc9d27632e37af22806c57dfa2dce5c401c0c Mon Sep 17 00:00:00 2001 From: Claudio Atzori Date: Thu, 23 Apr 2020 18:51:38 +0200 Subject: [PATCH] code formatting --- .../dnetlib/dhp/oa/dedup/SparkDedupTest.java | 34 +++++++++++++++---- 1 file changed, 27 insertions(+), 7 deletions(-) diff --git a/dhp-workflows/dhp-dedup-openaire/src/test/java/eu/dnetlib/dhp/oa/dedup/SparkDedupTest.java b/dhp-workflows/dhp-dedup-openaire/src/test/java/eu/dnetlib/dhp/oa/dedup/SparkDedupTest.java index 6a505ebb9..1773bbabd 100644 --- a/dhp-workflows/dhp-dedup-openaire/src/test/java/eu/dnetlib/dhp/oa/dedup/SparkDedupTest.java +++ b/dhp-workflows/dhp-dedup-openaire/src/test/java/eu/dnetlib/dhp/oa/dedup/SparkDedupTest.java @@ -118,7 +118,9 @@ public class SparkDedupTest implements Serializable { "/eu/dnetlib/dhp/dedup/conf/ds.curr.conf.json"))); lenient() - .when(isLookUpService.getResourceProfileByQuery(Mockito.contains("otherresearchproduct"))) + .when( + isLookUpService.getResourceProfileByQuery( + Mockito.contains("otherresearchproduct"))) .thenReturn( IOUtils.toString( SparkDedupTest.class.getResourceAsStream( @@ -164,7 +166,11 @@ public class SparkDedupTest implements Serializable { long orp_simrel = spark.read() - .load(testOutputBasePath + "/" + testActionSetId + "/otherresearchproduct_simrel") + .load( + testOutputBasePath + + "/" + + testActionSetId + + "/otherresearchproduct_simrel") .count(); assertEquals(3432, orgs_simrel); @@ -213,7 +219,11 @@ public class SparkDedupTest implements Serializable { long orp_mergerel = spark.read() - .load(testOutputBasePath + "/" + testActionSetId + "/otherresearchproduct_mergerel") + .load( + testOutputBasePath + + "/" + + testActionSetId + + "/otherresearchproduct_mergerel") .count(); assertEquals(1276, orgs_mergerel); @@ -254,7 +264,8 @@ public class SparkDedupTest implements Serializable { testOutputBasePath + "/" + testActionSetId - + "/publication_deduprecord").count(); + + "/publication_deduprecord") + .count(); long sw_deduprecord = jsc.textFile(testOutputBasePath + "/" + testActionSetId + "/software_deduprecord") .count(); @@ -262,7 +273,11 @@ public class SparkDedupTest implements Serializable { jsc.textFile(testOutputBasePath + "/" + testActionSetId + "/dataset_deduprecord") .count(); long orp_deduprecord = - jsc.textFile(testOutputBasePath + "/" + testActionSetId + "/otherresearchproduct_deduprecord") + jsc.textFile( + testOutputBasePath + + "/" + + testActionSetId + + "/otherresearchproduct_deduprecord") .count(); assertEquals(82, orgs_deduprecord); @@ -296,7 +311,8 @@ public class SparkDedupTest implements Serializable { long datasource = jsc.textFile(testDedupGraphBasePath + "/datasource").count(); long softwares = jsc.textFile(testDedupGraphBasePath + "/software").count(); long dataset = jsc.textFile(testDedupGraphBasePath + "/dataset").count(); - long otherresearchproduct = jsc.textFile(testDedupGraphBasePath + "/otherresearchproduct").count(); + long otherresearchproduct = + jsc.textFile(testDedupGraphBasePath + "/otherresearchproduct").count(); long mergedOrgs = spark.read() @@ -340,7 +356,11 @@ public class SparkDedupTest implements Serializable { long mergedOrp = spark.read() - .load(testOutputBasePath + "/" + testActionSetId + "/otherresearchproduct_mergerel") + .load( + testOutputBasePath + + "/" + + testActionSetId + + "/otherresearchproduct_mergerel") .as(Encoders.bean(Relation.class)) .where("relClass=='merges'") .javaRDD()