Minor optimization in EL FC reasoner

patrickwestphal · patrickwestphal · commit e128a0558303 · 2017-12-14T09:34:40.000+01:00
diff --git a/sansa-inference-spark/src/main/scala/net/sansa_stack/inference/spark/forwardchaining/triples/ForwardRuleReasonerEL.scala b/sansa-inference-spark/src/main/scala/net/sansa_stack/inference/spark/forwardchaining/triples/ForwardRuleReasonerEL.scala
@@ -310,7 +310,11 @@ class ForwardRuleReasonerEL (sc: SparkContext, parallelism: Int = 2) extends Tra
         val newCount = triplesRDD.count()
         logger.debug("New overall count: " + newCount)
         if (newCount > oldCount) {
-          rule.getInfluencedRules().foreach(rulesQueue.enqueue(_))
+          rule.getInfluencedRules().foreach(rule => {
+            if (!rulesQueue.contains(rule)) {
+              rulesQueue.enqueue(rule)
+            }
+          })
         }
       }
     }

Original file line number	Diff line number	Diff line change
`@@ -310,7 +310,11 @@ class ForwardRuleReasonerEL (sc: SparkContext, parallelism: Int = 2) extends Tra`
`310`	`310`	`val newCount = triplesRDD.count()`
`311`	`311`	`logger.debug("New overall count: " + newCount)`
`312`	`312`	`if (newCount > oldCount) {`
`313`		`- rule.getInfluencedRules().foreach(rulesQueue.enqueue(_))`
	`313`	`+ rule.getInfluencedRules().foreach(rule => {`
	`314`	`+ if (!rulesQueue.contains(rule)) {`
	`315`	`+ rulesQueue.enqueue(rule)`
	`316`	`+ }`
	`317`	`+ })`
`314`	`318`	`}`
`315`	`319`	`}`
`316`	`320`	`}`