From d55cfe0ea5a2c656747a3c3ff4a6105e0a3b38f7 Mon Sep 17 00:00:00 2001 From: "miriam.baglioni" Date: Thu, 13 Aug 2020 12:06:20 +0200 Subject: [PATCH] apply changes in https://code-repo.d4science.org/D-Net/dnet-hadoop/pulls/40#issuecomment-1832 --- .../graph/dump/community/SparkSplitForCommunity.java | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/dhp-workflows/dhp-graph-mapper/src/main/java/eu/dnetlib/dhp/oa/graph/dump/community/SparkSplitForCommunity.java b/dhp-workflows/dhp-graph-mapper/src/main/java/eu/dnetlib/dhp/oa/graph/dump/community/SparkSplitForCommunity.java index 0eeb68c2d..b62bf18e7 100644 --- a/dhp-workflows/dhp-graph-mapper/src/main/java/eu/dnetlib/dhp/oa/graph/dump/community/SparkSplitForCommunity.java +++ b/dhp-workflows/dhp-graph-mapper/src/main/java/eu/dnetlib/dhp/oa/graph/dump/community/SparkSplitForCommunity.java @@ -1,17 +1,19 @@ -/** - * Spark job to trigger the split of results associated to research community - reseach initiative/infrasctructure. - * The actual split is performed by the class CommunitySplit - */ package eu.dnetlib.dhp.oa.graph.dump.community; import java.io.Serializable; import java.util.Optional; + import org.apache.commons.io.IOUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; + import eu.dnetlib.dhp.application.ArgumentApplicationParser; +/** + * Spark job to trigger the split of results associated to research community - reseach initiative/infrasctructure. The + * actual split is performed by the class CommunitySplit + */ public class SparkSplitForCommunity implements Serializable { private static final Logger log = LoggerFactory.getLogger(SparkSplitForCommunity.class);