Apache Gelly -从边缘列表创建数据集

Question

我有一个这样创建的顶点和边的列表：

  val v1 = new Vertex(1L, "foo")
  val v2 = new Vertex(2L, "bar")
  val e1 = new Edge(v1, v2, 0.5)`

并希望使用Graph.fromDataSet方法(或任何其他方法)创建Flink图。我如何将这些边和顶点转换成对Flink来说可读的东西？

谢谢你！！

Answer 1

给定顶点val vertices: Seq[Vertex[Long, String]] = ...和边val edges: Seq[Edge[Long, String]] = ...的列表，您可以使用Graph.fromCollection方法创建Graph：

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)

值得注意的是，您必须导入org.apache.flink.graph.scala.Graph的Scala版本。

或者，您也可以首先使用edgeDataset: DataSet[Edge[Long, String]]和vertexDataSet: DataSet[Vertex[Long, String]]创建ExecutionEnvironment。然后可以创建一个Graph，调用Graph.fromDataSet方法：

val vertexDataset = env.fromCollection(vertices)
val edgeDataset = env.fromCollection(edges)

val graph = Graph.fromDataSet(vertexDataset, edgeDataset, env)