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

Commit 2ddb2f9

Browse files
Minor
1 parent 634099a commit 2ddb2f9

1 file changed

Lines changed: 8 additions & 3 deletions

File tree

sansa-inference-flink/src/main/scala/net/sansa_stack/inference/flink/RDFGraphMaterializer.scala

Lines changed: 8 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -93,15 +93,20 @@ object RDFGraphMaterializer {
9393
val inferredGraph = reasoner.apply(graph)
9494
// println(s"|G_inf| = ${inferredGraph.size}")
9595

96+
// println(env.getExecutionPlan())
97+
9698
// write triples to disk
9799
RDFGraphWriter.writeToDisk(inferredGraph, output, writeToSingleFile, sortedOutput)
98100

99-
// println(env.getExecutionPlan())
101+
// println(env.getExecutionPlan())
100102

101-
val jn = if (jobName.isEmpty) s"${profile} Reasoning" else jobName
103+
val jn = if (jobName.isEmpty) s"$profile Reasoning" else jobName
102104

103105
// run the program
104106
env.execute(jn)
107+
108+
109+
105110
}
106111

107112
// the config object
@@ -120,7 +125,7 @@ object RDFGraphMaterializer {
120125

121126
// the CLI parser
122127
val parser = new scopt.OptionParser[Config]("RDFGraphMaterializer") {
123-
head("RDFGraphMaterializer", "0.5.0")
128+
head("RDFGraphMaterializer", "0.6.0")
124129

125130
// opt[Seq[File]]('i', "input").required().valueName("<path1>,<path2>,...").
126131
// action((x, c) => c.copy(in = x)).

0 commit comments

Comments
 (0)