From 3bd3653be9e884679c390f8b9f9f36800b657692 Mon Sep 17 00:00:00 2001
From: Claudio Atzori <claudio.atzori@isti.cnr.it>
Date: Tue, 4 Jan 2022 15:02:09 +0100
Subject: [PATCH] OAF-store-graph mdstores: save them in text format

---
 .../main/java/eu/dnetlib/dhp/collection/CollectionUtils.scala | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/dhp-workflows/dhp-aggregation/src/main/java/eu/dnetlib/dhp/collection/CollectionUtils.scala b/dhp-workflows/dhp-aggregation/src/main/java/eu/dnetlib/dhp/collection/CollectionUtils.scala
index e7de60e07..86a28ac10 100644
--- a/dhp-workflows/dhp-aggregation/src/main/java/eu/dnetlib/dhp/collection/CollectionUtils.scala
+++ b/dhp-workflows/dhp-aggregation/src/main/java/eu/dnetlib/dhp/collection/CollectionUtils.scala
@@ -50,14 +50,16 @@ object CollectionUtils {
 
   def saveDataset(dataset: Dataset[Oaf], targetPath: String): Unit = {
     implicit val resultEncoder: Encoder[Oaf] = Encoders.kryo(classOf[Oaf])
+    val mapper = new ObjectMapper
 
     dataset
       .flatMap(i => CollectionUtils.fixRelations(i))
       .filter(i => i != null)
+      .map(r => mapper.writeValueAsString(r))(Encoders.STRING)
       .write
       .mode(SaveMode.Overwrite)
       .option("compression", "gzip")
-      .json(targetPath)
+      .text(targetPath)
   }
 
 }