enrico.ottonello
/
dnet-hadoop
forked from D-Net/dnet-hadoop
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

reformat code

This commit is contained in:
Sandro La Bruzzo 2020-08-06 10:30:22 +02:00
parent 4fb1821fab
commit a44e5abaa7
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
dhp-workflows/dhp-dedup-scholexplorer/src/main/java/eu/dnetlib/dedup/sx/SparkPropagateRelationsJob.java
View File

@ -1,7 +1,6 @@
package eu.dnetlib.dedup.sx; package eu.dnetlib.dedup.sx;
import eu.dnetlib.dhp.schema.scholexplorer.OafUtils;
import org.apache.commons.io.IOUtils; import org.apache.commons.io.IOUtils;
import org.apache.spark.api.java.function.MapFunction; import org.apache.spark.api.java.function.MapFunction;
import org.apache.spark.sql.Dataset; import org.apache.spark.sql.Dataset;
@ -11,6 +10,7 @@ import org.apache.spark.sql.SparkSession;
import eu.dnetlib.dhp.application.ArgumentApplicationParser; import eu.dnetlib.dhp.application.ArgumentApplicationParser;
import eu.dnetlib.dhp.schema.oaf.Relation; import eu.dnetlib.dhp.schema.oaf.Relation;
import eu.dnetlib.dhp.schema.scholexplorer.OafUtils;
import scala.Tuple2; import scala.Tuple2;
public class SparkPropagateRelationsJob { public class SparkPropagateRelationsJob {
@ -55,8 +55,8 @@ public class SparkPropagateRelationsJob {
final Relation relation = r._1(); final Relation relation = r._1();
if (mergeRelation != null) if (mergeRelation != null)
relation.setSource(mergeRelation.getSource()); relation.setSource(mergeRelation.getSource());
if (relation.getDataInfo()==null) if (relation.getDataInfo() == null)
relation.setDataInfo(OafUtils.generateDataInfo("0.9",false)); relation.setDataInfo(OafUtils.generateDataInfo("0.9", false));
return relation; return relation;
}, },
Encoders.bean(Relation.class)); Encoders.bean(Relation.class));