From 26363060edf42376c31492c35e2b6f63d1233dd9 Mon Sep 17 00:00:00 2001 From: Claudio Atzori Date: Fri, 3 May 2024 15:53:52 +0200 Subject: [PATCH] fixed id prefix creation for the fosnodoi records, again --- .../createunresolvedentities/PrepareFOSSparkJob.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/dhp-workflows/dhp-aggregation/src/main/java/eu/dnetlib/dhp/actionmanager/createunresolvedentities/PrepareFOSSparkJob.java b/dhp-workflows/dhp-aggregation/src/main/java/eu/dnetlib/dhp/actionmanager/createunresolvedentities/PrepareFOSSparkJob.java index dd85f6a4e..c248423d4 100644 --- a/dhp-workflows/dhp-aggregation/src/main/java/eu/dnetlib/dhp/actionmanager/createunresolvedentities/PrepareFOSSparkJob.java +++ b/dhp-workflows/dhp-aggregation/src/main/java/eu/dnetlib/dhp/actionmanager/createunresolvedentities/PrepareFOSSparkJob.java @@ -82,7 +82,8 @@ public class PrepareFOSSparkJob implements Serializable { .groupByKey((MapFunction) v -> v.getOaid().toLowerCase(), Encoders.STRING()) .mapGroups( (MapGroupsFunction) (k, - it) -> getResult(ModelSupport.entityIdPrefix.get(Result.class.getSimpleName()) + "|" + k, it), + it) -> getResult( + ModelSupport.entityIdPrefix.get(Result.class.getSimpleName().toLowerCase()) + "|" + k, it), Encoders.bean(Result.class)) .write() .mode(SaveMode.Overwrite)