How to print sortedVBC?

[yponcet]

Hi, I am trying to print the sortedVBC. I do not get errors by building the .jar file, but anything is shown when I run it. Please, this is my source code to do so:

val graph = Graph(vertices, edges, defaultVertex)

val k = 3

val kBCGraph = KBetweenness.run(graph, k)
   
val verticesBetweenness = kBCGraph.vertices.collect()
  
val sortedVBC = verticesBetweenness.sortWith((x,y) => x._1 < y._1)

println(s"${sortedVBC(0)._1} should equal (1L)")

Best and thanks in advance

[dmarcous]

Hi,
Can you please mention what isn't working correctly here?
Do you get the VBC values wrong? / sorted wrong? Are you getting anything at all?
Is the resulting graph empty? Maybe the original graph your are supplying is empty?
NOTE - your are sorting by node_ids not VBC values (graphX graph object is (id,value) so you need to use *._2 and not *._1).
Please attach the graph or a sample of the graph you are using to test whether this works correctly.
You can also try and run some of the tests here to get a hang of how to use the library on some example data

[yponcet]

Hi,
Now I could add your library to my project without errors, but I do not get any result when I run it on my graph. Please, here I attach a sample of it and my source code:

val sc = new SparkContext(new SparkConf().setAppName("Spark Count"))

val vertexArray = Array(
(1L, ("Alice", 28)),
(2L, ("Bob", 27)),
(3L, ("Charlie", 65)),
(4L, ("David", 42)),
(5L, ("Ed", 55)),
(6L, ("Fran", 50))
)
val edgeArray = Array(
Edge(2L, 1L, 7),
Edge(2L, 4L, 2),
Edge(3L, 2L, 4),
Edge(3L, 6L, 3),
Edge(4L, 1L, 1),
Edge(5L, 2L, 2),
Edge(5L, 3L, 8),
Edge(5L, 6L, 3)
)

val vertexRDD: RDD[(Long, (String, Int))] = sc.parallelize(vertexArray)
val edgeRDD: RDD[Edge[Int]] = sc.parallelize(edgeArray)

val graph: Graph[(String, Int), Int] = Graph(vertexRDD, edgeRDD)
val kBCGraph = KBetweenness.run(graph, 2)

val verticesBetweenness = kBCGraph.vertices.collect()

val sortedVBC = verticesBetweenness.sortWith((x,y) => x._1 < y._1)

println(s"$sortedVBC(0)._1")

[dmarcous]

Did you manage to get it to work?
Maybe not the recommended scala/spark version as on readme?