[createASfromAffRo] refactoring after compilation

This commit is contained in:
Miriam Baglioni 2024-10-18 16:22:51 +02:00
parent 0e5dd14538
commit 2b27afaec8
2 changed files with 4 additions and 3 deletions
dhp-workflows/dhp-graph-mapper/src
main/java/eu/dnetlib/dhp/oa/graph/hive
test/scala/eu/dnetlib/dhp/enrich/orcid

View File

@ -72,9 +72,9 @@ public class GraphHiveTableImporterJob {
final Encoder<T> clazzEncoder = Encoders.bean(clazz);
Dataset<Row> dataset = spark
.read()
.schema(clazzEncoder.schema())
.json(inputPath);
.read()
.schema(clazzEncoder.schema())
.json(inputPath);
if (numPartitions > 0) {
log.info("repartitioning {} to {} partitions", clazz.getSimpleName(), numPartitions);

View File

@ -31,6 +31,7 @@ class ORCIDAuthorMatchersTest {
assertTrue(matchOrderedTokenAndAbbreviations("孙林 Sun Lin", "Sun Lin"))
// assertTrue(AuthorsMatchRevised.compare("孙林 Sun Lin", "孙林")); // not yet implemented
}
@Test def testDocumentationNames(): Unit = {
assertTrue(matchOrderedTokenAndAbbreviations("James C. A. Miller-Jones", "James Antony Miller-Jones"))
}