org.apache.spark.graphx.lib
Class ConnectedComponents

Object
  org.apache.spark.graphx.lib.ConnectedComponents

public class ConnectedComponents
extends Object

Connected components algorithm.

Constructor Summary

ConnectedComponents()

Method Summary

static <VD,ED> Graph<Object,ED>

run(Graph<VD,ED> graph, scala.reflect.ClassTag<VD> evidence$1, scala.reflect.ClassTag<ED> evidence$2) Compute the connected component membership of each vertex and return a graph with the vertex value containing the lowest vertex id in the connected component containing that vertex.

Methods inherited from class Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ConnectedComponents

public ConnectedComponents()

Method Detail

run

public static <VD,ED> Graph<Object,ED> run(Graph<VD,ED> graph,
                                           scala.reflect.ClassTag<VD> evidence$1,
                                           scala.reflect.ClassTag<ED> evidence$2)

Compute the connected component membership of each vertex and return a graph with the vertex value containing the lowest vertex id in the connected component containing that vertex.

Parameters:

graph - the graph for which to compute the connected components

evidence$1 - (undocumented)

evidence$2 - (undocumented)

Returns:

a graph with vertex attributes containing the smallest vertex in each connected component