如何在 GraphX 中创建二分图

Question

我可以通过 GraphX API 使用 vertexRDD 和 edgeRDD 构建图表，没问题。即：

val graph: Graph[(String, Int), Int] = Graph(vertexRDD, edgeRDD)

但是，如果我想使用两个单独的 vertexRDD 而不是一个（二部图），我不知道从哪里开始。例如，包含购物者和产品顶点的图形。

我的问题很宽泛，所以我不期待一个详细的例子，而是一个正确方向的提示或推动。任何建议将不胜感激。

Answer 1

例如，将用户和产品建模为二分图，我们可以执行以下操作：

trait VertexProperty
case class UserProperty(val name: String) extends VertexProperty
case class ProductProperty(val name: String,
  val price: Double) extends VertexProperty

val users: RDD[(VertexId, VertexProperty)] = sc.parallelize(Seq(
  (1L, UserProperty("user1")), (2L, UserProperty("user2"))))

val products: RDD[(VertexId, VertexProperty)] = sc.parallelize(Seq(
  (1001L, ProductProperty("foo", 1.00)), (1002L, ProductProperty("bar", 3.99))))

val vertices = VertexRDD(users ++ products)

// The graph might then have the type:
val graph: Graph[VertexProperty, String] = null

如何在 GraphX 中创建二分图

How to create a bipartite graph in GraphX

graph

bipartite

apache-spark