From 6dfdba9ef7752403c539c793c0fd7868925d44c2 Mon Sep 17 00:00:00 2001 From: "miriam.baglioni" Date: Wed, 8 Apr 2020 18:14:37 +0200 Subject: [PATCH] new parametrized implementation for country propagation --- ...ssociation.java => PrepareDatasourceCountryAssociation.java} | 0 .../dhp/countrypropagation/SparkCountryPropagationJob2.java | 2 +- 2 files changed, 1 insertion(+), 1 deletion(-) rename dhp-workflows/dhp-propagation/src/main/java/eu/dnetlib/dhp/countrypropagation/{PrepareResultCountryAssociation.java => PrepareDatasourceCountryAssociation.java} (100%) diff --git a/dhp-workflows/dhp-propagation/src/main/java/eu/dnetlib/dhp/countrypropagation/PrepareResultCountryAssociation.java b/dhp-workflows/dhp-propagation/src/main/java/eu/dnetlib/dhp/countrypropagation/PrepareDatasourceCountryAssociation.java similarity index 100% rename from dhp-workflows/dhp-propagation/src/main/java/eu/dnetlib/dhp/countrypropagation/PrepareResultCountryAssociation.java rename to dhp-workflows/dhp-propagation/src/main/java/eu/dnetlib/dhp/countrypropagation/PrepareDatasourceCountryAssociation.java diff --git a/dhp-workflows/dhp-propagation/src/main/java/eu/dnetlib/dhp/countrypropagation/SparkCountryPropagationJob2.java b/dhp-workflows/dhp-propagation/src/main/java/eu/dnetlib/dhp/countrypropagation/SparkCountryPropagationJob2.java index 91b12b444..210d42f9c 100644 --- a/dhp-workflows/dhp-propagation/src/main/java/eu/dnetlib/dhp/countrypropagation/SparkCountryPropagationJob2.java +++ b/dhp-workflows/dhp-propagation/src/main/java/eu/dnetlib/dhp/countrypropagation/SparkCountryPropagationJob2.java @@ -123,7 +123,7 @@ public class SparkCountryPropagationJob2 { .option("compression", "gzip") .text(outputPath); } - + private static Dataset getPotentialResultToUpdate(SparkSession spark, String inputPath,