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

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

diff --git a/dhp-workflows/dhp-aggregation/src/main/scala/eu/dnetlib/dhp/collection/CollectionUtils.scala b/dhp-workflows/dhp-aggregation/src/main/scala/eu/dnetlib/dhp/collection/CollectionUtils.scala
index 26fcecbbd..509e464e5 100644
--- a/dhp-workflows/dhp-aggregation/src/main/scala/eu/dnetlib/dhp/collection/CollectionUtils.scala
+++ b/dhp-workflows/dhp-aggregation/src/main/scala/eu/dnetlib/dhp/collection/CollectionUtils.scala
@@ -56,7 +56,10 @@ object CollectionUtils {
       .flatMap(i => CollectionUtils.fixRelations(i))
       .filter(i => i != null)
       .map(r => mapper.writeValueAsString(r))(Encoders.STRING)
-      .write.mode(SaveMode.Overwrite).save(targetPath)
+      .write
+      .mode(SaveMode.Overwrite)
+      .option("compression", "gzip")
+      .text(targetPath)
   }
 
 }