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

Commit fc6caee

Browse files
committed
Align clustering algorithm with latest version of SANSA-ML
1 parent a3241bc commit fc6caee

File tree

4 files changed

+6
-6
lines changed

4 files changed

+6
-6
lines changed

sansa-examples-spark/src/main/scala/net/sansa_stack/examples/spark/ml/clustering/BorderFlowClustering.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@ package net.sansa_stack.examples.spark.ml.clustering
22

33
import scala.collection.mutable
44

5-
import net.sansa_stack.ml.spark.clustering.{ BorderFlow, FirstHardeninginBorderFlow }
5+
import net.sansa_stack.ml.spark.clustering.algorithms.FirstHardeninginBorderFlow
66
import net.sansa_stack.rdf.spark.io._
77
import net.sansa_stack.rdf.spark.model.graph._
88
import org.apache.jena.riot.Lang
@@ -36,10 +36,10 @@ object BorderFlowClustering {
3636

3737
val lang = Lang.NTRIPLES
3838
val triples = spark.rdf(lang)(input)
39-
val graph = triples.asStringGraph()
39+
val graph = triples.asGraph()
4040

4141
val borderflow = algName match {
42-
case "borderflow" => BorderFlow(spark, graph, output, outputevlsoft, outputevlhard)
42+
// case "borderflow" => BorderFlow(spark, graph, output, outputevlsoft, outputevlhard)
4343
case "firsthardening" => FirstHardeninginBorderFlow(spark, graph, output, outputevlhard)
4444
case _ =>
4545
throw new RuntimeException("'" + algName + "' - Not supported, yet.")

sansa-examples-spark/src/main/scala/net/sansa_stack/examples/spark/ml/clustering/RDFByModularityClustering.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@ package net.sansa_stack.examples.spark.ml.clustering
22

33
import scala.collection.mutable
44

5-
import net.sansa_stack.ml.spark.clustering.{ RDFByModularityClustering => RDFByModularityClusteringAlg }
5+
import net.sansa_stack.ml.spark.clustering.algorithms.{ RDFByModularityClustering => RDFByModularityClusteringAlg }
66
import org.apache.log4j.{ Level, Logger }
77
import org.apache.spark.sql.SparkSession
88

sansa-examples-spark/src/main/scala/net/sansa_stack/examples/spark/ml/clustering/RDFGraphPIClustering.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@ package net.sansa_stack.examples.spark.ml.clustering
22

33
import scala.collection.mutable
44

5-
import net.sansa_stack.ml.spark.clustering.RDFGraphPowerIterationClustering
5+
import net.sansa_stack.ml.spark.clustering.algorithms.RDFGraphPowerIterationClustering
66
import net.sansa_stack.rdf.spark.io._
77
import net.sansa_stack.rdf.spark.model.graph._
88
import org.apache.jena.riot.{ Lang, RDFDataMgr }

sansa-examples-spark/src/main/scala/net/sansa_stack/examples/spark/ml/clustering/SilviaClustering.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,7 @@ package net.sansa_stack.examples.spark.ml.clustering
22

33
import scala.collection.mutable
44

5-
import net.sansa_stack.ml.spark.clustering.{ SilviaClustering => AlgSilviaClustering }
5+
import net.sansa_stack.ml.spark.clustering.algorithms.{ SilviaClustering => AlgSilviaClustering }
66
import net.sansa_stack.rdf.spark.io._
77
import net.sansa_stack.rdf.spark.model.graph._
88
import org.apache.jena.riot.Lang

0 commit comments

Comments
 (0)