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

Commit 653b058

Browse files
committed
Align owl examples for Flink
1 parent 64b0b2e commit 653b058

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

sansa-examples-flink/src/main/scala/net/sansa_stack/examples/flink/owl/OWLReaderDataSet.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2,8 +2,8 @@ package net.sansa_stack.examples.flink.owl
22

33
import scala.collection.mutable
44

5+
import net.sansa_stack.owl.flink.owl._
56
import org.apache.flink.api.scala.ExecutionEnvironment
6-
import net.sansa_stack.owl.flink.dataset.{ FunctionalSyntaxOWLAxiomsDataSetBuilder, ManchesterSyntaxOWLAxiomsDataSetBuilder }
77

88

99
object OWLReaderDataSet {
@@ -26,8 +26,8 @@ object OWLReaderDataSet {
2626
val env = ExecutionEnvironment.getExecutionEnvironment
2727

2828
val dataSet = syntax match {
29-
case "fun" => FunctionalSyntaxOWLAxiomsDataSetBuilder.build(env, input)
30-
case "manch" => ManchesterSyntaxOWLAxiomsDataSetBuilder.build(env, input)
29+
case "fun" => env.owl(Syntax.FUNCTIONAL)(input)
30+
case "manch" => env.owl(Syntax.MANCHESTER)(input)
3131
case "owl_xml" =>
3232
throw new RuntimeException("'" + syntax + "' - Not supported, yet.")
3333
case _ =>

0 commit comments

Comments
 (0)