GraphX、Scalaで2つのノード間の距離を計算するには？

Question

すべてのノードとシンクノードとの間の最大距離を計算します。シンクノードは、外縁を持たないノードである。私は最短距離の機能を発見したが、最大距離を知りたい。

Answer 1

GraphX内の任意の2つのノード間の最大距離を計算するには、コードはこのようにすることができ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"))