Skip to content
This repository was archived by the owner on Oct 8, 2020. It is now read-only.

Commit b5e03b2

Browse files
Scalastyle cleanup
1 parent 2ddb2f9 commit b5e03b2

2 files changed

Lines changed: 1 addition & 21 deletions

File tree

sansa-inference-flink/src/main/scala/net/sansa_stack/inference/flink/data/RDFGraphLoader.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,7 @@ object RDFGraphLoader {
3939
val ds = RDFGraphLoader.loadFromDisk(path, env).triples
4040

4141
println(s"size:${ds.count}")
42-
println("sample data:\n" + ds.first(10).map { _.toString.replaceAll("[\\x00-\\x1f]","???")}.collect().mkString("\n"))
42+
println("sample data:\n" + ds.first(10).map { _.toString.replaceAll("[\\x00-\\x1f]", "???")}.collect().mkString("\n"))
4343
}
4444

4545
}

sansa-inference-flink/src/main/scala/net/sansa_stack/inference/flink/forwardchaining/ForwardRuleReasoner.scala

Lines changed: 0 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -68,26 +68,6 @@ trait ForwardRuleReasoner extends TransitiveReasoner{
6868
subject: Option[Node],
6969
predicate: Option[Node],
7070
obj: Option[Node]): DataSet[Triple] = {
71-
// import net.sansa_stack.inference.utils.PredicateUtils._
72-
// var extractedTriples = triples
73-
// var filter = (t: Triple) => true
74-
//
75-
// if(subject.isDefined) {
76-
// filter = filter || (_.subjectMatches(subject.get))
77-
//// extractedTriples = extractedTriples.filter(triple => triple.subjectMatches(subject.get))
78-
// }
79-
//
80-
// if(predicate.isDefined) {
81-
// filter = filter || (_.predicateMatches(predicate.get))
82-
//// extractedTriples = extractedTriples.filter(triple => triple.predicateMatches(predicate.get))
83-
// }
84-
//
85-
// if(obj.isDefined) {
86-
// filter = filter || (_.objectMatches(obj.get))
87-
//// extractedTriples = extractedTriples.filter(triple => triple.objectMatches(obj.get))
88-
// }
89-
//
90-
// extractedTriples.filter(filter)
9171

9272
val filterFct = (t: Triple) =>
9373
t.subjectMatches(subject.orNull) ||

0 commit comments

Comments
 (0)