diff --git a/dump/src/main/java/eu/dnetlib/dhp/oa/graph/dump/eosc/SparkSelectRelation.java b/dump/src/main/java/eu/dnetlib/dhp/oa/graph/dump/eosc/SparkSelectRelation.java index 6f02871..5c2fe14 100644 --- a/dump/src/main/java/eu/dnetlib/dhp/oa/graph/dump/eosc/SparkSelectRelation.java +++ b/dump/src/main/java/eu/dnetlib/dhp/oa/graph/dump/eosc/SparkSelectRelation.java @@ -80,14 +80,12 @@ public class SparkSelectRelation implements Serializable { Dataset> resultIds = Utils .readPath(spark, outputPath + "/publication", Result.class) - .map( (MapFunction>) p -> new Tuple2<>(p.getId(), p.getType()), Encoders.tuple(Encoders.STRING(), Encoders.STRING())) .union( Utils .readPath(spark, outputPath + "/dataset", Result.class) - .map( (MapFunction>) d -> new Tuple2<>(d.getId(), d.getType()), Encoders.tuple(Encoders.STRING(), Encoders.STRING())))