タイプ不一致FLINKグラフコミュニティ

Question

私はコミュニティの検出のための非常に簡単なコードを実行しようとしていますが、それはエラーを返します：

import org.apache.flink.graph.library.CommunityDetection 
import org.apache.flink.graph._ 
import org.apache.flink.graph.scala.Graph 
import java.lang.Long 
import java.lang.Double 
import org.apache.flink.api.scala._ 

val env = ExecutionEnvironment.getExecutionEnvironment 
val vertices = Seq(new Vertex[Long, String](1L, "foo"), new Vertex[Long, String](2L, "bar")) 
val edges = Seq(new Edge[Long, String](1L, 2L, "foobar")) 

val graph = Graph.fromCollection(vertices, edges, env) 
val updatedGraph = graph.mapVertices(v => v.getValue + 1) 
val resultGraph = graph.run(new CommunityDetection[Long](30, 0.5)) 


          ^

Answer 1

CommunityDetectionアルゴリズムはLongのIdsと頂点値とDouble辺の重みを持つGraphを期待しています。コードでは、頂点とエッジの値をStringと定義します。 詳しい使用方法については、at the Gelly documentationをご覧ください。