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

Commit 35780ec

Browse files
authored
Merge pull request #33 from SANSA-Stack/fix/inference-flink-example
Fix inference example for Flink based on the inference layer changes
2 parents 4bf31f9 + 8cc0a82 commit 35780ec

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

sansa-examples-flink/src/main/scala/net/sansa_stack/examples/flink/inference/RDFGraphInference.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -72,7 +72,7 @@ object RDFGraphInference {
7272

7373
// load triples from disk
7474
val graph = RDFGraphLoader.loadFromDisk(input, env)
75-
println(s"|G| = ${graph.size()}")
75+
println(s"|G| = ${graph.size}")
7676

7777
// create reasoner
7878
val reasoner = profile match {
@@ -88,7 +88,7 @@ object RDFGraphInference {
8888

8989
// compute inferred graph
9090
val inferredGraph = reasoner.apply(graph)
91-
println(s"|G_inf| = ${inferredGraph.size()}")
91+
println(s"|G_inf| = ${inferredGraph.size}")
9292

9393
val jn = if (jobName.isEmpty) s"RDF Graph Inference ($profile)" else jobName
9494
}

0 commit comments

Comments
 (0)