From 1402eb1fe7e7a0599003b5afbe8ab7e519a0ae32 Mon Sep 17 00:00:00 2001 From: Claudio Atzori Date: Wed, 1 Apr 2020 15:38:50 +0200 Subject: [PATCH] cleanup --- .../dhp/oa/provision/GraphJoiner_v2.java | 20 ------------------- 1 file changed, 20 deletions(-) diff --git a/dhp-workflows/dhp-graph-provision/src/main/java/eu/dnetlib/dhp/oa/provision/GraphJoiner_v2.java b/dhp-workflows/dhp-graph-provision/src/main/java/eu/dnetlib/dhp/oa/provision/GraphJoiner_v2.java index d67493f43..236ef93ec 100644 --- a/dhp-workflows/dhp-graph-provision/src/main/java/eu/dnetlib/dhp/oa/provision/GraphJoiner_v2.java +++ b/dhp-workflows/dhp-graph-provision/src/main/java/eu/dnetlib/dhp/oa/provision/GraphJoiner_v2.java @@ -58,26 +58,6 @@ public class GraphJoiner_v2 implements Serializable { StructField$.MODULE$.apply("value", DataTypes.StringType, false, Metadata.empty()) )); - private static final StructType TYPED_ROW_SCHEMA = StructType$.MODULE$.apply( - Arrays.asList( - StructField$.MODULE$.apply("sourceId", DataTypes.StringType, false, Metadata.empty()), - StructField$.MODULE$.apply("targetId", DataTypes.StringType, true, Metadata.empty()), - StructField$.MODULE$.apply("deleted", DataTypes.BooleanType, false, Metadata.empty()), - StructField$.MODULE$.apply("type", DataTypes.StringType, false, Metadata.empty()), - StructField$.MODULE$.apply("relType", DataTypes.StringType, true, Metadata.empty()), - StructField$.MODULE$.apply("subRelType", DataTypes.StringType, true, Metadata.empty()), - StructField$.MODULE$.apply("relClass", DataTypes.StringType, true, Metadata.empty()), - StructField$.MODULE$.apply("oaf", DataTypes.BinaryType, false, Metadata.empty()) - )); - - private static final StructType ENTITY_REL_ENTITY_SCHEMA = StructType$.MODULE$.apply( - Arrays.asList( - StructField$.MODULE$.apply("source", TYPED_ROW_SCHEMA, false, Metadata.empty()), - StructField$.MODULE$.apply("relation", TYPED_ROW_SCHEMA, true, Metadata.empty()), - StructField$.MODULE$.apply("target", TYPED_ROW_SCHEMA, false, Metadata.empty()) - )); - - private SparkSession spark; private ContextMapper contextMapper;