scala - 使用pregel graphx激发一条最短的一对一路径

我试图使用link中的代码找到从单个源到n个顶点的最短路径

val graph: Graph[Long, Double] =
  GraphGenerators.logNormalGraph(sc, numVertices = 100).mapEdges(e => e.attr.toDouble)
val sourceId: VertexId = 42

val initialGraph = graph.mapVertices((id, _) =>
    if (id == sourceId) 0.0 else Double.PositiveInfinity)
val sssp = initialGraph.pregel(Double.PositiveInfinity)(
  (id, dist, newDist) => math.min(dist, newDist),
  triplet => {
    if (triplet.srcAttr + triplet.attr < triplet.dstAttr) {
      Iterator((triplet.dstId, triplet.srcAttr + triplet.attr))
    } else {
      Iterator.empty
    }
  },
  (a, b) => math.min(a, b)
)
println(sssp.vertices.collect.mkString("\n"))

它为我提供了从42个顶点到N个顶点的最短路径。
但是，如何找到单个来源到单个目的地之间的最短路径？
即source = 42，dest = 135然后我想找到它们之间的最短路径。

谢谢

最佳答案

否则，您将无法找到两个顶点之间的最短距离，即不浏览整个图形。因为即使目的地收到您的消息后，即使您停止探索，也无法保证它是最短的距离。
因此，该算法在复杂度方面很好。您应该只从获得的不同目标中选择sssp值。