miriam.baglioni
/
dnet-hadoop
forked from D-Net/dnet-hadoop
2
0
Fork 0
Code Issues 2 Pull Requests Releases Wiki Activity

fixed typo

This commit is contained in:
Miriam Baglioni 2020-07-17 18:49:45 +02:00
parent 5ed688af83
commit 70d33920e2
3 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
dhp-workflows/dhp-actionset-remapping/src/main/java/eu/dnetlib/dhp/actionset/stable/SparkRedistributeIISRelations.java
View File

@ -114,7 +114,7 @@ public class SparkRedistributeIISRelations implements Serializable {
private static DataInfo getDataInfo(ASResultInfo asResultInfo) { private static DataInfo getDataInfo(ASResultInfo asResultInfo) {
DataInfo di = new DataInfo(); DataInfo di = new DataInfo();
di.setInvisible(false); di.setInvisible(false);
di.setInvisible(true); di.setInferred(true);
di.setDeletedbyinference(false); di.setDeletedbyinference(false);
di.setTrust(asResultInfo.getValue().get(0).getTrust()); di.setTrust(asResultInfo.getValue().get(0).getTrust());
di.setInferenceprovenance(asResultInfo.getValue().get(0).getInference_provenance()); di.setInferenceprovenance(asResultInfo.getValue().get(0).getInference_provenance());

2
dhp-workflows/dhp-actionset-remapping/src/main/resources/eu/dnetlib/dhp/actionset/oozie_app/workflow.xml
View File

@ -158,7 +158,7 @@
<master>yarn</master> <master>yarn</master>
<mode>cluster</mode> <mode>cluster</mode>
<name>SelectResults</name> <name>SelectResults</name>
<class>eu.dnetlib.dhp.actionset.stable.SparkRedistributeIISResult</class> <class>eu.dnetlib.dhp.actionset.stable.SparkRedistributeIISResults</class>
<jar>dhp-actionset-remapping-${projectVersion}.jar</jar> <jar>dhp-actionset-remapping-${projectVersion}.jar</jar>
<spark-opts> <spark-opts>
--executor-cores=${sparkExecutorCores} --executor-cores=${sparkExecutorCores}

4
dhp-workflows/dhp-actionset-remapping/src/test/java/eu/dnetlib/dhp/actionset/RedistributeIISLinksTest.java
View File

@ -22,8 +22,8 @@ import org.slf4j.LoggerFactory;
import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.databind.ObjectMapper;
import eu.dnetlib.dhp.actionmanager.remapping.SparkRedistributeIISResult;
import eu.dnetlib.dhp.actionset.stable.SparkRedistributeIISRelations; import eu.dnetlib.dhp.actionset.stable.SparkRedistributeIISRelations;
import eu.dnetlib.dhp.actionset.stable.SparkRedistributeIISResults;
import eu.dnetlib.dhp.schema.action.AtomicAction; import eu.dnetlib.dhp.schema.action.AtomicAction;
import eu.dnetlib.dhp.schema.oaf.Relation; import eu.dnetlib.dhp.schema.oaf.Relation;
import eu.dnetlib.dhp.schema.oaf.Result; import eu.dnetlib.dhp.schema.oaf.Result;
@ -148,7 +148,7 @@ public class RedistributeIISLinksTest {
@Test @Test
public void redistributeTestResult() throws Exception { public void redistributeTestResult() throws Exception {
SparkRedistributeIISResult SparkRedistributeIISResults
.main( .main(
new String[] { new String[] {
"-isSparkSessionManaged", "-isSparkSessionManaged",