dnet-hadoop/dhp-workflows/dhp-dedup/src/test/java/eu/dnetlib/dedup/SparkCreateDedupTest.java

72 lines
1.9 KiB
Java
Raw Normal View History

2019-12-06 13:38:00 +01:00
package eu.dnetlib.dedup;
import com.fasterxml.jackson.databind.ObjectMapper;
import eu.dnetlib.dhp.application.ArgumentApplicationParser;
import eu.dnetlib.dhp.schema.oaf.Publication;
2019-12-06 13:38:00 +01:00
import org.apache.commons.io.FileUtils;
import org.apache.commons.io.IOUtils;
import org.junit.Before;
import org.junit.Ignore;
import org.junit.Test;
import java.io.File;
import java.io.IOException;
import java.util.List;
2019-12-06 13:38:00 +01:00
public class SparkCreateDedupTest {
String configuration;
2019-12-13 12:20:35 +01:00
String entity = "publication";
2019-12-06 13:38:00 +01:00
@Before
public void setUp() throws IOException {
2019-12-13 12:20:35 +01:00
configuration = IOUtils.toString(getClass().getResourceAsStream("/eu/dnetlib/dedup/conf/pub_dt.curr.conf.json"));
2019-12-06 13:38:00 +01:00
}
2019-12-06 13:38:00 +01:00
@Test
@Ignore
public void createSimRelsTest() throws Exception {
2019-12-06 13:38:00 +01:00
SparkCreateSimRels.main(new String[] {
"-mt", "local[*]",
"-s", "/home/sandro/betadump",
"-e", entity,
"-c", ArgumentApplicationParser.compressArgument(configuration),
2019-12-06 13:38:00 +01:00
"-t", "/tmp/dedup",
});
}
@Test
@Ignore
public void createCCTest() throws Exception {
2019-12-06 13:38:00 +01:00
SparkCreateConnectedComponent.main(new String[] {
"-mt", "local[*]",
"-s", "/home/sandro/betadump",
"-e", entity,
"-c", ArgumentApplicationParser.compressArgument(configuration),
2019-12-06 13:38:00 +01:00
"-t", "/tmp/dedup",
});
}
@Test
@Ignore
public void dedupRecordTest() throws Exception {
SparkCreateDedupRecord.main(new String[] {
"-mt", "local[*]",
"-s", "/home/sandro/betadump",
"-e", entity,
"-c", ArgumentApplicationParser.compressArgument(configuration),
"-d", "/tmp/dedup",
2019-12-06 13:38:00 +01:00
});
}
@Test
public void printCC() throws Exception {
System.out.println(ArgumentApplicationParser.compressArgument(configuration));
}
2019-12-06 13:38:00 +01:00
}