This commit is contained in:
Miriam Baglioni 2020-03-23 14:35:23 +01:00
parent 30d58fd98c
commit 8ab8b6b0bf
1 changed files with 1 additions and 1 deletions

View File

@ -88,7 +88,7 @@ public class SparkCountryPropagationJob {
final JavaRDD<Row> toupdateresultdataset = propagateOnResult(spark, "openaire.dataset");
final JavaRDD<Row> toupdateresultother = propagateOnResult(spark, "openaire.otherresearchproduct");
final JavaRDD<Row> toupdateresultpublication = propagateOnResult(spark, "openaire.publication");
writeUpdates(toupdateresultsoftware, toupdateresultdataset, toupdateresultother, toupdateresultpublication, outputPath);
createUpdateForSoftwareDataset(toupdateresultsoftware, inputPath, spark)