lsmyrnaios
/
dnet-hadoop
forked from D-Net/dnet-hadoop
1
0
Fork 0
Code Pull Requests Activity

fixed issue and changed the transformation of the programme file to consider the new model

This commit is contained in:
Miriam Baglioni 2020-09-25 13:32:34 +02:00
parent e917281822
commit 969fa8d96e
3 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
dhp-workflows/dhp-aggregation/src/main/java/eu/dnetlib/dhp/actionmanager/project/ReadProjectsFromDB.java
View File

@ -33,7 +33,7 @@ public class ReadProjectsFromDB implements Closeable {
private final BufferedWriter writer;
private final ObjectMapper OBJECT_MAPPER = new ObjectMapper();
private final static String query = "SELECT code , optional1, optional2" +
private final static String query = "SELECT code , optional1, optional2 " +
"from projects where id like 'corda__h2020%' ";
public static void main(final String[] args) throws Exception {

2
dhp-workflows/dhp-aggregation/src/main/java/eu/dnetlib/dhp/actionmanager/project/SparkAtomicActionJob.java
View File

@ -147,7 +147,7 @@ public class SparkAtomicActionJob {
}
private static void setLevels(H2020Classification h2020Classification, String classification) {
String[] tmp = classification.split(" | ");
String[] tmp = classification.split(" \\| ");
h2020Classification.setLevel1(tmp[0]);
if (tmp.length > 1) {
h2020Classification.setLevel2(tmp[1]);

4
dhp-workflows/dhp-aggregation/src/test/java/eu/dnetlib/dhp/actionmanager/project/CSVParserTest.java
View File

@ -7,10 +7,14 @@ import java.nio.file.Path;
import java.util.List;
import org.apache.commons.io.IOUtils;
import org.apache.spark.api.java.function.FilterFunction;
import org.junit.jupiter.api.BeforeAll;
import org.junit.jupiter.api.Test;
import com.google.gson.Gson;
import eu.dnetlib.dhp.actionmanager.project.csvutils.CSVParser;
import eu.dnetlib.dhp.actionmanager.project.csvutils.CSVProgramme;
public class CSVParserTest {