Make Flink module Scala-style compliant

GezimSejdiu · GezimSejdiu · commit 7b28bc8edd73 · 2018-11-12T13:17:55.000+01:00
diff --git a/sansa-examples-flink/src/main/scala/net/sansa_stack/examples/flink/inference/RDFGraphInference.scala b/sansa-examples-flink/src/main/scala/net/sansa_stack/examples/flink/inference/RDFGraphInference.scala
@@ -7,18 +7,17 @@ import java.util.Properties
 import scala.io.Source
 
 import com.typesafe.config.ConfigFactory
-import org.apache.flink.api.java.utils.ParameterTool
-import org.apache.flink.api.scala.ExecutionEnvironment
-import org.apache.flink.configuration.Configuration
-import org.apache.flink.runtime.webmonitor.WebMonitorUtils
-
 import net.sansa_stack.inference.flink.data.{ RDFGraphLoader, RDFGraphWriter }
 import net.sansa_stack.inference.flink.forwardchaining.{
   ForwardRuleReasonerOWLHorst,
   ForwardRuleReasonerRDFS
 }
-import net.sansa_stack.inference.rules.ReasoningProfile._
 import net.sansa_stack.inference.rules.{ RDFSLevel, ReasoningProfile }
+import net.sansa_stack.inference.rules.ReasoningProfile._
+import org.apache.flink.api.java.utils.ParameterTool
+import org.apache.flink.api.scala.ExecutionEnvironment
+import org.apache.flink.configuration.Configuration
+import org.apache.flink.runtime.webmonitor.WebMonitorUtils
 
 object RDFGraphInference {
 
@@ -40,14 +39,14 @@ object RDFGraphInference {
   }
 
   def run(
-    args:              Array[String],
-    input:             Seq[URI],
-    output:            URI,
-    profile:           ReasoningProfile,
+    args: Array[String],
+    input: Seq[URI],
+    output: URI,
+    profile: ReasoningProfile,
     writeToSingleFile: Boolean,
-    sortedOutput:      Boolean,
-    propertiesFile:    File,
-    jobName:           String): Unit = {
+    sortedOutput: Boolean,
+    propertiesFile: File,
+    jobName: String): Unit = {
 
     // read reasoner optimization properties
     val reasonerConf =
@@ -99,13 +98,13 @@ object RDFGraphInference {
 
   // the config object
   case class Config(
-    in:                Seq[URI]         = Seq(),
-    out:               URI              = new URI("."),
-    profile:           ReasoningProfile = ReasoningProfile.RDFS,
-    writeToSingleFile: Boolean          = false,
-    sortedOutput:      Boolean          = false,
-    propertiesFile:    File             = null,
-    jobName:           String           = "") // new File(getClass.getResource("reasoner.properties").toURI)
+    in: Seq[URI] = Seq(),
+    out: URI = new URI("."),
+    profile: ReasoningProfile = ReasoningProfile.RDFS,
+    writeToSingleFile: Boolean = false,
+    sortedOutput: Boolean = false,
+    propertiesFile: File = null,
+    jobName: String = "") // new File(getClass.getResource("reasoner.properties").toURI)
 
   // read ReasoningProfile enum
   implicit val profilesRead: scopt.Read[ReasoningProfile.Value] =
@@ -159,4 +158,4 @@ object RDFGraphInference {
 
   }
   parser.showUsageOnError
-}
+}
diff --git a/sansa-examples-flink/src/main/scala/net/sansa_stack/examples/flink/ml/clustering/RDFByModularityClustering.scala b/sansa-examples-flink/src/main/scala/net/sansa_stack/examples/flink/ml/clustering/RDFByModularityClustering.scala
@@ -1,11 +1,12 @@
 package net.sansa_stack.examples.flink.ml.clustering
+
 import scala.collection.mutable
+
 import net.sansa_stack.ml.flink.clustering.{ RDFByModularityClustering => RDFByModularityClusteringAlg }
-import org.apache.flink.api.scala.ExecutionEnvironment
 import org.apache.flink.api.scala._
+import org.apache.flink.api.scala.ExecutionEnvironment
 
 object RDFByModularityClustering {
-  
   def main(args: Array[String]) {
     parser.parse(args, Config()) match {
       case Some(config) =>
@@ -49,4 +50,4 @@ object RDFByModularityClustering {
 
     help("help").text("prints this usage text")
   }
-}
+}
diff --git a/sansa-examples-flink/src/main/scala/net/sansa_stack/examples/flink/owl/OWLReaderDataSet.scala b/sansa-examples-flink/src/main/scala/net/sansa_stack/examples/flink/owl/OWLReaderDataSet.scala
@@ -1,9 +1,10 @@
 package net.sansa_stack.examples.flink.owl
 
-import net.sansa_stack.owl.flink.dataset.{ FunctionalSyntaxOWLAxiomsDataSetBuilder, ManchesterSyntaxOWLAxiomsDataSetBuilder }
+import scala.collection.mutable
+
 import org.apache.flink.api.scala.ExecutionEnvironment
+import net.sansa_stack.owl.flink.dataset.{ FunctionalSyntaxOWLAxiomsDataSetBuilder, ManchesterSyntaxOWLAxiomsDataSetBuilder }
 
-import scala.collection.mutable
 
 object OWLReaderDataSet {
 
@@ -20,12 +21,12 @@ object OWLReaderDataSet {
 
     println(".============================================.")
     println("| Dataset OWL reader example (" + syntax + " syntax)|")
-    println("`============================================´")
+    println(".============================================.")
 
     val env = ExecutionEnvironment.getExecutionEnvironment
 
     val dataSet = syntax match {
-      case "fun"   => FunctionalSyntaxOWLAxiomsDataSetBuilder.build(env, input)
+      case "fun" => FunctionalSyntaxOWLAxiomsDataSetBuilder.build(env, input)
       case "manch" => ManchesterSyntaxOWLAxiomsDataSetBuilder.build(env, input)
       case "owl_xml" =>
         throw new RuntimeException("'" + syntax + "' - Not supported, yet.")
@@ -38,7 +39,7 @@ object OWLReaderDataSet {
   }
 
   case class Config(
-    in:     String = "",
+    in: String = "",
     syntax: String = "")
 
   // the CLI parser
@@ -56,4 +57,4 @@ object OWLReaderDataSet {
 
     help("help").text("prints this usage text")
   }
-}
+}
diff --git a/sansa-examples-flink/src/main/scala/net/sansa_stack/examples/flink/rdf/RDFStats.scala b/sansa-examples-flink/src/main/scala/net/sansa_stack/examples/flink/rdf/RDFStats.scala
@@ -1,10 +1,12 @@
 package net.sansa_stack.examples.flink.rdf
 
-import scala.collection.mutable
 import java.io.File
-import org.apache.flink.api.scala.ExecutionEnvironment
+
+import scala.collection.mutable
+
 import net.sansa_stack.rdf.flink.data.RDFGraphLoader
 import net.sansa_stack.rdf.flink.stats.RDFStatistics
+import org.apache.flink.api.scala.ExecutionEnvironment
 
 object RDFStats {
 
@@ -36,7 +38,7 @@ object RDFStats {
   }
 
   case class Config(
-    in:  String = "",
+    in: String = "",
     out: String = "")
 
   // the CLI parser
@@ -54,4 +56,4 @@ object RDFStats {
 
     help("help").text("prints this usage text")
   }
-}
+}
diff --git a/sansa-examples-flink/src/main/scala/net/sansa_stack/examples/flink/rdf/TripleOps.scala b/sansa-examples-flink/src/main/scala/net/sansa_stack/examples/flink/rdf/TripleOps.scala
@@ -1,9 +1,11 @@
 package net.sansa_stack.examples.flink.rdf
 
 import scala.collection.mutable
-import org.apache.flink.api.scala.ExecutionEnvironment
+
 import net.sansa_stack.rdf.flink.data.RDFGraphLoader
 import org.apache.flink.api.scala._
+import org.apache.flink.api.scala.ExecutionEnvironment
+
 
 object TripleOps {
   def main(args: Array[String]) {
@@ -25,16 +27,16 @@ object TripleOps {
     val rdfgraph = RDFGraphLoader.loadFromFile(input, env)
 
     rdfgraph.triples.collect().take(4).foreach(println(_))
-    //Triples filtered by subject ( "http://dbpedia.org/resource/Charles_Dickens" )
+    // Triples filtered by subject ( "http://dbpedia.org/resource/Charles_Dickens" )
     println("All triples related to Dickens:\n" + rdfgraph.find(Some("http://commons.dbpedia.org/resource/Category:Places"), None, None).collect().mkString("\n"))
 
-    //Triples filtered by predicate ( "http://dbpedia.org/ontology/influenced" )
+    // Triples filtered by predicate ( "http://dbpedia.org/ontology/influenced" )
     println("All triples for predicate influenced:\n" + rdfgraph.find(None, Some("http://dbpedia.org/ontology/influenced"), None).collect().mkString("\n"))
 
-    //Triples filtered by object ( <http://dbpedia.org/resource/Henry_James> )
+    // Triples filtered by object ( <http://dbpedia.org/resource/Henry_James> )
     println("All triples influenced by Henry_James:\n" + rdfgraph.find(None, None, Some("<http://dbpedia.org/resource/Henry_James>")).collect().mkString("\n"))
 
-    //println("Number of triples: " + rdfgraph.triples.distinct.count())
+    // println("Number of triples: " + rdfgraph.triples.distinct.count())
     println("Number of subjects: " + rdfgraph.getSubjects.map(_.toString).distinct().count)
     println("Number of predicates: " + rdfgraph.getPredicates.map(_.toString).distinct.count())
     println("Number of objects: " + rdfgraph.getPredicates.map(_.toString).distinct.count())
@@ -52,4 +54,4 @@ object TripleOps {
     help("help").text("prints this usage text")
   }
 
-}
+}
diff --git a/sansa-examples-flink/src/main/scala/net/sansa_stack/examples/flink/rdf/TripleReader.scala b/sansa-examples-flink/src/main/scala/net/sansa_stack/examples/flink/rdf/TripleReader.scala
@@ -1,8 +1,10 @@
 package net.sansa_stack.examples.flink.rdf
 
 import scala.collection.mutable
-import org.apache.flink.api.scala.ExecutionEnvironment
+
 import net.sansa_stack.rdf.flink.data.RDFGraphLoader
+import org.apache.flink.api.scala.ExecutionEnvironment
+
 
 object TripleReader {
 
@@ -40,4 +42,4 @@ object TripleReader {
 
     help("help").text("prints this usage text")
   }
-}
+}
diff --git a/sansa-examples-flink/src/main/scala/net/sansa_stack/examples/flink/rdf/TripleWriter.scala b/sansa-examples-flink/src/main/scala/net/sansa_stack/examples/flink/rdf/TripleWriter.scala
@@ -1,7 +1,9 @@
 package net.sansa_stack.examples.flink.rdf
+
 import scala.collection.mutable
-import org.apache.flink.api.scala.ExecutionEnvironment
+
 import net.sansa_stack.rdf.flink.data.{ RDFGraphLoader, RDFGraphWriter }
+import org.apache.flink.api.scala.ExecutionEnvironment
 
 object TripleWriter {
 
@@ -30,7 +32,7 @@ object TripleWriter {
   }
 
   case class Config(
-    in:  String = "",
+    in: String = "",
     out: String = "")
 
   val parser = new scopt.OptionParser[Config]("Triple writer example ") {
