From ac46c247d2261c2dc2a1c5845d6355ca5088537f Mon Sep 17 00:00:00 2001
From: Claudio Atzori <claudio.atzori@isti.cnr.it>
Date: Tue, 2 Feb 2021 14:24:00 +0100
Subject: [PATCH] code formatting

---
 .../dhp/transformation/TransformSparkJobNode.java  | 14 +++++++-------
 1 file changed, 7 insertions(+), 7 deletions(-)

diff --git a/dhp-workflows/dhp-aggregation/src/main/java/eu/dnetlib/dhp/transformation/TransformSparkJobNode.java b/dhp-workflows/dhp-aggregation/src/main/java/eu/dnetlib/dhp/transformation/TransformSparkJobNode.java
index e1830ed28..e1b1b849c 100644
--- a/dhp-workflows/dhp-aggregation/src/main/java/eu/dnetlib/dhp/transformation/TransformSparkJobNode.java
+++ b/dhp-workflows/dhp-aggregation/src/main/java/eu/dnetlib/dhp/transformation/TransformSparkJobNode.java
@@ -92,13 +92,13 @@ public class TransformSparkJobNode {
 		final Encoder<MetadataRecord> encoder = Encoders.bean(MetadataRecord.class);
 
 		final Dataset<MetadataRecord> mdstore = spark
-				.read()
-				.format("parquet")
-				.load(inputPath)
-				.as(encoder)
-				.map(
-						TransformationFactory.getTransformationPlugin(args, ct, isLookUpService),
-						encoder);
+			.read()
+			.format("parquet")
+			.load(inputPath)
+			.as(encoder)
+			.map(
+				TransformationFactory.getTransformationPlugin(args, ct, isLookUpService),
+				encoder);
 		saveDataset(mdstore, outputBasePath + MDSTORE_DATA_PATH);
 
 		log.info("Transformed item " + ct.getProcessedItems().count());