diff --git a/dump/src/main/java/eu/dnetlib/dhp/oa/graph/dump/organizationonly/SparkDumpOrganizationJob.java b/dump/src/main/java/eu/dnetlib/dhp/oa/graph/dump/organizationonly/SparkDumpOrganizationJob.java index db020b4..814fdb2 100644 --- a/dump/src/main/java/eu/dnetlib/dhp/oa/graph/dump/organizationonly/SparkDumpOrganizationJob.java +++ b/dump/src/main/java/eu/dnetlib/dhp/oa/graph/dump/organizationonly/SparkDumpOrganizationJob.java @@ -93,7 +93,7 @@ public class SparkDumpOrganizationJob implements Serializable { private static void organizationMap(SparkSession spark, String inputPath, String outputPath) { Utils - .readPath(spark, inputPath + "/organization", eu.dnetlib.dhp.schema.oaf.Organization.class) + .readPath(spark, inputPath , eu.dnetlib.dhp.schema.oaf.Organization.class) .filter( (FilterFunction) o -> !o.getDataInfo().getDeletedbyinference() && o.getId().startsWith("20|openorgs")) @@ -104,7 +104,7 @@ public class SparkDumpOrganizationJob implements Serializable { .write() .mode(SaveMode.Overwrite) .option(COMPRESSION, GZIP) - .json(outputPath + "/openorgs"); + .json(outputPath ); } private static eu.dnetlib.dhp.oa.model.graph.Organization mapOrganization(