Graphframes:spark graphframes 中两个顶点列表之间的 BFS

cap*_*roo 5 apache-spark spark-graphx graphframes

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

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

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

Col1, Col2, OP
a1,   a4,   true
a2,   a1,   false
a3,   a5,   true
Run Code Online (Sandbox Code Playgroud)

目前,我正在循环每一行并应用 bfs,如下所示

gf.bfs.fromExpr("id = 'a1'").toExpr("id = 'a4'").maxPathLength(4).run()
Run Code Online (Sandbox Code Playgroud)

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