Join 运算符中的 match 到底是什么意思

Question

我很困惑。我正在尝试做一个看起来相当简单的连接操作，但它没有像我预期的那样工作。我有两个图表，pGraph 和 cGraph。每个都是通过从 CSV 文件中读取条目构建的，所使用的 id 值是从其中一个属性生成的。 pGraph 包含 p 顶点，这些顶点完全充实了属性，cGraph 包含 c 个类似定义的顶点。在 pGraph 中，在 p 顶点和 c 顶点之间定义了边，使用一致的 id 值。但是，由于 c 顶点的属性仅在 cGraph 中可用，我想将两个图连接在一起，以便 c 顶点（来自 cGraph）和 p 顶点的属性（来自 pGraph ) 在连接结果中定义 (xGraph).

这是我认为可以实现此目的的代码：

val xGraph = pGraph.joinVertices(cGraph.vertices){ (x,y,z) => z}

最后，通过调试，我发现map函数根本就没有被调用过。也就是说 pGraph 和 cGraph 中显然没有匹配的顶点。我曾假设如果 id 值相同，就会匹配。但这似乎不是真的。如果匹配基于顶点的两个组件（id 和属性），那么当然不会有匹配，因为在一种情况下属性为空，而在另一种情况下它是正确的值。

从 this 和 input 顶点相同的意义上来说，我发现的连接操作示例都是微不足道的，而不是来自不同的图表。

有什么建议吗？

Answer 1

这是我得到的：

scala> val g1 = Graph.fromEdges[Double,Double](edges,0.0)
scala> val g2 = Graph.fromEdges[Double,Double](edges,2.0)
scala> val g3 = g1.joinVertices(g2.vertices){ (vid,num1,nu2) => 2.0 }
scala> g3.vertices.toArray.foreach(println(_))
(4,2.0)
(1,2.0)
(5,2.0)
(2,2.0)
(3,2.0)

这正是我所期望的。

能否分享完全重现您所见内容的代码？

Join 运算符中的 match 到底是什么意思

What exactly is meant by match in Join operators

spark-graphx