Hi Trevor,
note that the community detection algorithm returns a new graph where the
vertex values correspond to the computed communities. Also, note that the
current implementation expects a graph with java.lang.Long vertex values
and java.lang.Double edge values.
The following should work:
imp
Recall facing a similar issue while trying to contribute a gelly-scala
example to flink-training.
See
https://github.com/dataArtisans/flink-training-exercises/blob/master/src/main/scala/com/dataartisans/flinktraining/exercises/gelly_scala/PageRankWithEdgeWeights.scala
On Wed, Apr 27, 2016 at 11:3
The following example in the scala shell worked as expected:
import org.apache.flink.graph.library.LabelPropagation
val verticesWithCommunity = graph.run(new LabelPropagation(30))
// print the result
verticesWithCommunity.print
I tried to extend the example to use CommunityDetection:
import o
