changed the test to mirror the change in the logic of the code
This commit is contained in:
parent
5022f1b50d
commit
26cf32c066
|
@ -88,7 +88,7 @@ public class DumpOrganizationProjectDatasourceTest {
|
||||||
org.apache.spark.sql.Dataset<eu.dnetlib.dhp.schema.dump.oaf.graph.Organization> verificationDataset = spark
|
org.apache.spark.sql.Dataset<eu.dnetlib.dhp.schema.dump.oaf.graph.Organization> verificationDataset = spark
|
||||||
.createDataset(tmp.rdd(), Encoders.bean(eu.dnetlib.dhp.schema.dump.oaf.graph.Organization.class));
|
.createDataset(tmp.rdd(), Encoders.bean(eu.dnetlib.dhp.schema.dump.oaf.graph.Organization.class));
|
||||||
|
|
||||||
Assertions.assertEquals(34, verificationDataset.count());
|
Assertions.assertEquals(15, verificationDataset.count());
|
||||||
|
|
||||||
verificationDataset
|
verificationDataset
|
||||||
.foreach(
|
.foreach(
|
||||||
|
|
Loading…
Reference in New Issue