apache-flink - 类型不匹配 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算法需要一个Graph具有LongIds 和顶点值和Double边权重的值。在您的代码中，您定义String顶点和边的值。请查看Gelly 文档以获取更详细的使用信息。