Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Remove unusable variables #94

Closed
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Original file line number Diff line number Diff line change
Expand Up @@ -19,8 +19,6 @@ import scala.collection.mutable.ListBuffer
object BetweennessCentralityAlgo {
private val LOGGER = Logger.getLogger(this.getClass)

val ALGORITHM: String = "BetweennessCentrality"

/**
* run the BetweennessCentrality algorithm for nebula graph
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -19,8 +19,6 @@ import org.apache.spark.sql.{DataFrame, Dataset, Row, SparkSession}
object BfsAlgo {
private val LOGGER = Logger.getLogger(this.getClass)

val ALGORITHM: String = "BFS"

/**
* run the louvain algorithm for nebula graph
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,6 @@ import org.apache.spark.sql.{DataFrame, Dataset, Row, SparkSession}

object ClosenessAlgo {
private val LOGGER = Logger.getLogger(this.getClass)
val ALGORITHM: String = "Closeness"
type SPMap = Map[VertexId, Double]

private def makeMap(x: (VertexId, Double)*) = Map(x: _*)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,8 +16,6 @@ import org.apache.spark.sql.{DataFrame, Dataset, Row, SparkSession}
object ClusteringCoefficientAlgo {
private val LOGGER = Logger.getLogger(this.getClass)

val ALGORITHM: String = "ClusterCoefficientAlgo"

/**
* run the clusterCoefficient algorithm for nebula graph
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -18,8 +18,6 @@ import org.apache.spark.sql.{DataFrame, Dataset, Row, SparkSession}
object ConnectedComponentsAlgo {
private val LOGGER = Logger.getLogger(this.getClass)

val ALGORITHM: String = "ConnectedComponents"

/**
* run the ConnectedComponents algorithm for nebula graph
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,8 +17,6 @@ object DegreeStaticAlgo {

private val LOGGER = Logger.getLogger(this.getClass)

val ALGORITHM: String = "DegreeStatic"

/**
* run the pagerank algorithm for nebula graph
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -18,8 +18,6 @@ import org.apache.spark.sql.{DataFrame, Dataset, Row, SparkSession}
* The implementation of the algorithm refers to paper `Towards real-time community detection in large networks`.
*/
object HanpAlgo {
val ALGORITHM: String = "Hanp"

/**
* run the Hanp algorithm for nebula graph
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,8 +24,6 @@ import org.apache.spark.sql.types.{DoubleType, StringType, StructField, StructTy
object JaccardAlgo {
private val LOGGER = Logger.getLogger(this.getClass)

val ALGORITHM: String = "Jaccard"

/**
* run the Jaccard algorithm for nebula graph
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -15,8 +15,6 @@ import org.apache.spark.sql.{DataFrame, Dataset, Row, SparkSession}
object KCoreAlgo {
private val LOGGER = Logger.getLogger(this.getClass)

val ALGORITHM: String = "KCore"

/**
* run the louvain algorithm for nebula graph
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -18,8 +18,6 @@ import org.apache.spark.sql.{DataFrame, Dataset, Row, SparkSession}
object LabelPropagationAlgo {
private val LOGGER = Logger.getLogger(this.getClass)

val ALGORITHM: String = "LabelPropagation"

/**
* run the LabelPropagation algorithm for nebula graph
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,8 +20,6 @@ import scala.collection.mutable.{HashMap, HashSet}
object LouvainAlgo {
private val LOGGER = Logger.getLogger(this.getClass)

val ALGORITHM: String = "Louvain"

/**
* run the louvain algorithm for nebula graph
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -33,7 +33,6 @@ case class EdgeAttr(var dstNeighbors: Array[Long] = Array.empty[Long],
* Here is the code url https://github.com/aditya-grover/node2vec.git.
*/
object Node2vecAlgo {
val ALGORITHM: String = "Node2vec"
var node2vecConfig: Node2vecConfig = _
var context: SparkContext = _
var indexedEdges: RDD[Edge[EdgeAttr]] = _
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,8 +17,6 @@ import org.apache.spark.sql.{DataFrame, Dataset, Row, SparkSession}
object PageRankAlgo {
private val LOGGER = Logger.getLogger(this.getClass)

val ALGORITHM: String = "PageRank"

/**
* run the pagerank algorithm for nebula graph
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,8 +21,6 @@ import org.apache.spark.sql.{DataFrame, Dataset, Row, SparkSession}
object ShortestPathAlgo {
private val LOGGER = Logger.getLogger(this.getClass)

val ALGORITHM: String = "ShortestPath"

/**
* run the ShortestPath algorithm for nebula graph
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -16,8 +16,6 @@ import org.apache.spark.sql.types.{LongType, StructField, StructType}

object StronglyConnectedComponentsAlgo {

val ALGORITHM: String = "StronglyConnectedComponents"

/**
* run the StronglyConnectedComponents algorithm for nebula graph
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,8 +17,6 @@ import org.apache.spark.sql.types.{IntegerType, LongType, StructField, StructTyp
object TriangleCountAlgo {
private val LOGGER = Logger.getLogger(this.getClass)

val ALGORITHM: String = "TriangleCount"

/**
* run the TriangleCount algorithm for nebula graph
*
Expand Down
Loading