[DumpCSV] fixing issues

This commit is contained in:
Miriam Baglioni 2023-07-05 09:58:55 +02:00
parent e87b790a60
commit 8a44653dbe
1 changed files with 4 additions and 4 deletions

View File

@ -149,9 +149,9 @@ public class SparkDumpResults implements Serializable {
ar.setRank(String.valueOf(count));
}
}
ar.setFirstName(a.getName());
ar.setLastName(a.getSurname());
ar.setFullName(a.getFullname());
ar.setFirstName(a.getName().replace("\t", " ").replace("\n", " ").replace("\r", " "));
ar.setLastName(a.getSurname().replace("\t", " ").replace("\n", " ").replace("\r", " "));
ar.setFullName(a.getFullname().replace("\t", " ").replace("\n", " ").replace("\r", " "));
Tuple2<String, Boolean> orcid = getOrcid(a.getPid());
if (Optional.ofNullable(orcid).isPresent()) {
ar.setOrcid(orcid._1());
@ -207,7 +207,7 @@ public class SparkDumpResults implements Serializable {
.distinct()
.map(p -> {
CSVPid ret = new CSVPid();
ret.setId(DHPUtils.md5(p));
ret.setId(DHPUtils.md5(p + "@" + resultId));
ret.setResult_id(resultId);
ret.setPid(split(p, "@")[1]);
ret.setType(split(p, "@")[0]);