apache-spark - Graphframes：Spark Graphframes 中两个顶点列表之间的 BFS

Question

我的目标是找出两个顶点之间的最大路径长度是否<= 4。

我有一个图形数据框和一个以下格式的测试文件。

我正在尝试从图形数据帧的 bfs 函数中获取输出列（OP）。

Col1, Col2, OP
a1,   a4,   true
a2,   a1,   false
a3,   a5,   true

目前，我正在遍历每一行并应用如下 bfs

gf.bfs.fromExpr("id = 'a1'").toExpr("id = 'a4'").maxPathLength(4).run()

有没有更好的方法可以直接在源和目的地插入顶点列表来计算图形框架中的 bfs。

标签： apache-sparkspark-graphxgraphframes