diff --git a/nebula-algorithm/src/main/scala/com/vesoft/nebula/algorithm/Main.scala b/nebula-algorithm/src/main/scala/com/vesoft/nebula/algorithm/Main.scala index 4aa1812..4b41472 100644 --- a/nebula-algorithm/src/main/scala/com/vesoft/nebula/algorithm/Main.scala +++ b/nebula-algorithm/src/main/scala/com/vesoft/nebula/algorithm/Main.scala @@ -22,7 +22,8 @@ import com.vesoft.nebula.algorithm.config.{ Node2vecConfig, PRConfig, ShortestPathConfig, - SparkConfig + SparkConfig, + DegreeStaticConfig } import com.vesoft.nebula.algorithm.lib.{ BetweennessCentralityAlgo, @@ -171,7 +172,8 @@ object Main { ShortestPathAlgo(spark, dataSet, spConfig, hasWeight) } case "degreestatic" => { - DegreeStaticAlgo(spark, dataSet) + val dsConfig = DegreeStaticConfig.getDegreeStaticConfig(configs) + DegreeStaticAlgo(spark, dataSet, dsConfig) } case "kcore" => { val kCoreConfig = KCoreConfig.getKCoreConfig(configs)