diff --git a/dump/src/test/java/eu/dnetlib/dhp/oa/graph/dump/eosc/ExtendProjectTest.java b/dump/src/test/java/eu/dnetlib/dhp/oa/graph/dump/eosc/ExtendProjectTest.java index d463b57..c3ef919 100644 --- a/dump/src/test/java/eu/dnetlib/dhp/oa/graph/dump/eosc/ExtendProjectTest.java +++ b/dump/src/test/java/eu/dnetlib/dhp/oa/graph/dump/eosc/ExtendProjectTest.java @@ -162,57 +162,6 @@ public class ExtendProjectTest { } - @Test - public void selectEoscResults() throws Exception { - - final String sourcePath = getClass() - .getResource("/eu/dnetlib/dhp/oa/graph/dump/eosc/input") - .getPath(); - - final String workingPath = getClass() - .getResource("/eu/dnetlib/dhp/oa/graph/dump/eosc/working/") - .getPath(); - - final JavaSparkContext sc = JavaSparkContext.fromSparkContext(spark.sparkContext()); - - spark - .read() - .textFile(workingPath + "publication") - .write() - .text(workingDir.toString() + "/working/publicationextendedaffiliation"); - - spark - .read() - .textFile(workingPath + "preparedInfo") - .write() - .text(workingDir.toString() + "/working/preparedInfo"); - - ExtendEoscResultWithOrganizationStep2.main(new String[] { - "-isSparkSessionManaged", Boolean.FALSE.toString(), - "-outputPath", workingDir.toString() + "/", - "-sourcePath", sourcePath, - "-resultType", "publication", - "-workingPath", workingDir.toString() + "/working/" - }); - - - JavaRDD tmp = sc - .textFile(workingDir.toString() + "/organization") - .map(item -> OBJECT_MAPPER.readValue(item, Organization.class)); - - JavaRDD rels = sc - .textFile(workingDir.toString() + "/resultProject") - .map(item -> OBJECT_MAPPER.readValue(item, Relation.class)); - - System.out.println(tmp.count()); - - Assertions.assertEquals(2, tmp.count()); - - Assertions.assertEquals(2, rels.count()); - - rels.foreach(r -> Assertions.assertTrue(r.getSource().startsWith("50|"))); - rels.foreach(r -> Assertions.assertTrue(r.getTarget().startsWith("20|"))); - - } + }