diff --git a/dnet-dedup-test/pom.xml b/dnet-dedup-test/pom.xml
index b2101fe..3ae6742 100644
--- a/dnet-dedup-test/pom.xml
+++ b/dnet-dedup-test/pom.xml
@@ -63,7 +63,7 @@
eu.dnetlib
dnet-openaireplus-mapping-utils
- test
+
diff --git a/dnet-dedup-test/src/main/java/eu/dnetlib/SparkTest.java b/dnet-dedup-test/src/main/java/eu/dnetlib/SparkTest.java
index 93c3bda..ff3a59b 100644
--- a/dnet-dedup-test/src/main/java/eu/dnetlib/SparkTest.java
+++ b/dnet-dedup-test/src/main/java/eu/dnetlib/SparkTest.java
@@ -1,6 +1,5 @@
package eu.dnetlib;
-import com.google.common.collect.Lists;
import com.google.common.collect.Sets;
import eu.dnetlib.graph.GraphProcessor;
import eu.dnetlib.pace.clustering.BlacklistAwareClusteringCombiner;
@@ -34,13 +33,13 @@ public class SparkTest {
public static void main(String[] args) {
final JavaSparkContext context = new JavaSparkContext(new SparkConf().setAppName("Deduplication").setMaster("local[*]"));
- final URL dataset = SparkTest.class.getResource("/eu/dnetlib/pace/orgs.json");
+ final URL dataset = SparkTest.class.getResource("/eu/dnetlib/pace/results.json");
final JavaRDD dataRDD = context.textFile(dataset.getPath());
counter = new SparkCounter(context);
//read the configuration from the classpath
- final DedupConfig config = DedupConfig.load(readFromClasspath("/eu/dnetlib/pace/organization.test2.pace.conf"));
+ final DedupConfig config = DedupConfig.load(readFromClasspath("/eu/dnetlib/pace/result.full.pace.conf"));
BlockProcessor.constructAccumulator(config);
BlockProcessor.accumulators.forEach(acc -> {
diff --git a/dnet-dedup-test/src/main/java/eu/dnetlib/data/transform/AbstractProtoMapper.java b/dnet-dedup-test/src/main/java/eu/dnetlib/data/transform/AbstractProtoMapper.java
deleted file mode 100644
index 2d5a6e0..0000000
--- a/dnet-dedup-test/src/main/java/eu/dnetlib/data/transform/AbstractProtoMapper.java
+++ /dev/null
@@ -1,150 +0,0 @@
-package eu.dnetlib.data.transform;
-
-import java.util.List;
-
-import org.apache.commons.lang.StringUtils;
-
-import com.google.common.base.Splitter;
-import com.google.common.collect.Iterables;
-import com.google.common.collect.Lists;
-import com.google.protobuf.Descriptors.EnumValueDescriptor;
-import com.google.protobuf.Descriptors.FieldDescriptor;
-import com.google.protobuf.GeneratedMessage;
-import com.google.protobuf.Message;
-import com.googlecode.protobuf.format.JsonFormat;
-
-import eu.dnetlib.pace.config.Type;
-
-/**
- * AbstractProtoMapper provide common navigation methods on the protocolbuffers Messages.
- *
- * @author claudio
- */
-public abstract class AbstractProtoMapper {
-
- private static final String COND_WRAPPER = "\\{|\\}";
- private static final String COND_SEPARATOR = "#";
- /** The Constant PATH_SEPARATOR. */
- private static final String PATH_SEPARATOR = "/";
-
- /**
- * Process multi path.
- *
- * @param proto
- * the proto
- * @param paths
- * the paths
- * @return the list
- */
- protected List