From c0d2b62e46ed1e88412862b28ad11c40a3343c6d Mon Sep 17 00:00:00 2001 From: Claudio Atzori Date: Fri, 18 Jun 2021 15:57:41 +0200 Subject: [PATCH] [doiboost] added missing implicit Encoder --- .../java/eu/dnetlib/doiboost/crossref/SparkMapDumpIntoOAF.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dhp-workflows/dhp-doiboost/src/main/java/eu/dnetlib/doiboost/crossref/SparkMapDumpIntoOAF.scala b/dhp-workflows/dhp-doiboost/src/main/java/eu/dnetlib/doiboost/crossref/SparkMapDumpIntoOAF.scala index 01bf9dd62..ee3229f1f 100644 --- a/dhp-workflows/dhp-doiboost/src/main/java/eu/dnetlib/doiboost/crossref/SparkMapDumpIntoOAF.scala +++ b/dhp-workflows/dhp-doiboost/src/main/java/eu/dnetlib/doiboost/crossref/SparkMapDumpIntoOAF.scala @@ -33,9 +33,9 @@ object SparkMapDumpIntoOAF { implicit val mapEncoderPubs: Encoder[Publication] = Encoders.kryo[Publication] implicit val mapEncoderRelatons: Encoder[Relation] = Encoders.kryo[Relation] implicit val mapEncoderDatasets: Encoder[oaf.Dataset] = Encoders.kryo[OafDataset] + implicit val mrEncoder: Encoder[CrossrefDT] = Encoders.kryo[CrossrefDT] val targetPath = parser.get("targetPath") - import spark.implicits._ spark.read.load(parser.get("sourcePath")).as[CrossrefDT] .flatMap(k => Crossref2Oaf.convert(k.json))