Как рассчитать расстояние между двумя узлами в GraphX, Scala?

Question

Я хочу рассчитать максимальное расстояние между каждым узлом до узла приемника. Узел раковины является узлом без внешних ребер. Я нашел функцию для кратчайшего расстояния, но я хочу знать максимальное расстояние.

Answer 1

Чтобы рассчитать максимальное расстояние между любыми двумя узлами в GraphX, вы можете использовать Pregel API

Код может быть таким:

import org.apache.spark.graphx.{Graph, VertexId}
import org.apache.spark.graphx.util.GraphGenerators

// A graph with edge attributes containing distances
val graph: Graph[Long, Double] =
  GraphGenerators.logNormalGraph(sc, numVertices = 100).mapEdges(e => e.attr.toDouble)
val sourceId: VertexId = 42 // The ultimate source
// Initialize the graph such that all vertices except the root have distance infinity.
val initialGraph = graph.mapVertices((id, _) =>
    if (id == sourceId) 0.0 else Double.PositiveInfinity)
val sssp = initialGraph.pregel(Double.PositiveInfinity)(
  (id, dist, newDist) => math.max(dist, newDist), // Vertex Program
  triplet => {  // Send Message
    if (triplet.srcAttr + triplet.attr < triplet.dstAttr) {
      Iterator((triplet.dstId, triplet.srcAttr + triplet.attr))
    } else {
      Iterator.empty
    }
  },
  (a, b) => math.max(a, b) // Merge Message
)
println(sssp.vertices.collect.mkString("\n"))