Update ForwardRuleReasonerOWLHorst.scala

Hebaallahibrahim · web-flow · commit 3120a15f31b8 · 2019-01-09T10:34:03.000+01:00
diff --git a/sansa-inference-spark/src/main/scala/net/sansa_stack/inference/spark/forwardchaining/axioms/ForwardRuleReasonerOWLHorst.scala b/sansa-inference-spark/src/main/scala/net/sansa_stack/inference/spark/forwardchaining/axioms/ForwardRuleReasonerOWLHorst.scala
@@ -609,8 +609,10 @@ class ForwardRuleReasonerOWLHorst (sc: SparkContext, parallelism: Int = 2) exten
 
    // println("\n Finish with " + inferedAxioms.count + " Inferred Axioms after adding SameAs rules")
     println("\n...finished materialization in " + (time/1000) + " sec.")
+   
+    val inferedGraph = inferedAxioms.union(axioms)
 
-    inferedAxioms
+    inferedGraph
   }
 
   def extractAxiom(axiom: RDD[OWLAxiom], T: AxiomType[_]): RDD[OWLAxiom] = {

Original file line number	Diff line number	Diff line change
`@@ -609,8 +609,10 @@ class ForwardRuleReasonerOWLHorst (sc: SparkContext, parallelism: Int = 2) exten`
`609`	`609`
`610`	`610`	`// println("\n Finish with " + inferedAxioms.count + " Inferred Axioms after adding SameAs rules")`
`611`	`611`	`println("\n...finished materialization in " + (time/1000) + " sec.")`
	`612`	`+`
	`613`	`+ val inferedGraph = inferedAxioms.union(axioms)`
`612`	`614`
`613`		`- inferedAxioms`
	`615`	`+ inferedGraph`
`614`	`616`	`}`
`615`	`617`
`616`	`618`	`def extractAxiom(axiom: RDD[OWLAxiom], T: AxiomType[_]): RDD[OWLAxiom] = {`