From 9bae991167975bbe1419945bee2c390a962ad1b3 Mon Sep 17 00:00:00 2001 From: "miriam.baglioni" Date: Tue, 11 Aug 2020 11:20:43 +0200 Subject: [PATCH] added description of the class --- .../graph/dump/community/SparkDumpCommunityProducts.java | 7 ++++--- .../oa/graph/dump/community/SparkPrepareResultProject.java | 7 +++++++ .../oa/graph/dump/community/SparkSplitForCommunity.java | 4 ++++ 3 files changed, 15 insertions(+), 3 deletions(-) diff --git a/dhp-workflows/dhp-graph-mapper/src/main/java/eu/dnetlib/dhp/oa/graph/dump/community/SparkDumpCommunityProducts.java b/dhp-workflows/dhp-graph-mapper/src/main/java/eu/dnetlib/dhp/oa/graph/dump/community/SparkDumpCommunityProducts.java index 6a1dced83..225b3d5bb 100644 --- a/dhp-workflows/dhp-graph-mapper/src/main/java/eu/dnetlib/dhp/oa/graph/dump/community/SparkDumpCommunityProducts.java +++ b/dhp-workflows/dhp-graph-mapper/src/main/java/eu/dnetlib/dhp/oa/graph/dump/community/SparkDumpCommunityProducts.java @@ -1,3 +1,7 @@ +/** + *Spark action to trigger the dump of results associated to research community - reseach initiative/infrasctructure + * The actual dump if performed via the class DumpProducts that is used also for the entire graph dump + */ package eu.dnetlib.dhp.oa.graph.dump.community; @@ -10,15 +14,12 @@ import org.slf4j.LoggerFactory; import eu.dnetlib.dhp.application.ArgumentApplicationParser; import eu.dnetlib.dhp.oa.graph.dump.DumpProducts; -import eu.dnetlib.dhp.oa.graph.dump.QueryInformationSystem; -import eu.dnetlib.dhp.oa.graph.dump.Utils; import eu.dnetlib.dhp.schema.dump.oaf.community.CommunityResult; import eu.dnetlib.dhp.schema.oaf.Result; public class SparkDumpCommunityProducts implements Serializable { private static final Logger log = LoggerFactory.getLogger(SparkDumpCommunityProducts.class); - private static QueryInformationSystem queryInformationSystem; public static void main(String[] args) throws Exception { String jsonConfiguration = IOUtils diff --git a/dhp-workflows/dhp-graph-mapper/src/main/java/eu/dnetlib/dhp/oa/graph/dump/community/SparkPrepareResultProject.java b/dhp-workflows/dhp-graph-mapper/src/main/java/eu/dnetlib/dhp/oa/graph/dump/community/SparkPrepareResultProject.java index a9d44d9c1..c7b0a76a9 100644 --- a/dhp-workflows/dhp-graph-mapper/src/main/java/eu/dnetlib/dhp/oa/graph/dump/community/SparkPrepareResultProject.java +++ b/dhp-workflows/dhp-graph-mapper/src/main/java/eu/dnetlib/dhp/oa/graph/dump/community/SparkPrepareResultProject.java @@ -1,3 +1,10 @@ +/** + * Preparation of the Project information to be added to the dumped results. + * For each result associated to at least one Project, a serialization of an instance af ResultProject closs is done. + * ResultProject contains the resultId, and the list of Projects (as in eu.dnetlib.dhp.schema.dump.oaf.community.Project) + * it is associated to + * + */ package eu.dnetlib.dhp.oa.graph.dump.community; 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 d190369f9..0eeb68c2d 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,3 +1,7 @@ +/** + * 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;