From d32b0861a2f0f93e0ac54bbc79d7ae3c8327e7ff Mon Sep 17 00:00:00 2001 From: "miriam.baglioni" Date: Fri, 10 Nov 2023 14:55:09 +0100 Subject: [PATCH] - --- .../eu/dnetlib/dhp/oa/graph/dump/eosc/SparkSelectRelation.java | 2 -- 1 file changed, 2 deletions(-) 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())))