org.apache.flink.graph.library

Class GSAConnectedComponents<K,EV>

java.lang.Object

org.apache.flink.graph.library.GSAConnectedComponents<K,EV>

All Implemented Interfaces:

GraphAlgorithm<K,Long,EV,DataSet<Vertex<K,Long>>>

public class GSAConnectedComponents<K,EV>
extends Object
implements GraphAlgorithm<K,Long,EV,DataSet<Vertex<K,Long>>>

This is an implementation of the Connected Components algorithm, using a gather-sum-apply iteration. This implementation assumes that the vertices of the input Graph are initialized with unique, Long component IDs. The result is a DataSet of vertices, where the vertex value corresponds to the assigned component ID.

See Also:

ConnectedComponents

Constructor Summary

Constructors

Constructor and Description
GSAConnectedComponents(Integer maxIterations) Creates an instance of the GSA Connected Components algorithm.

Method Summary

Modifier and Type	Method and Description
DataSet<Vertex<K,Long>>	run(Graph<K,Long,EV> graph)

Methods inherited from class java.lang.Object

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

Constructor Detail

GSAConnectedComponents

public GSAConnectedComponents(Integer maxIterations)

Creates an instance of the GSA Connected Components algorithm. The algorithm computes weakly connected components and converges when no vertex updates its component ID or when the maximum number of iterations has been reached.

Parameters:

maxIterations - The maximum number of iterations to run.

Method Detail

run

public DataSet<Vertex<K,Long>> run(Graph<K,Long,EV> graph)
                            throws Exception

Specified by:

run in interface GraphAlgorithm<K,Long,EV,DataSet<Vertex<K,Long>>>

Throws:

Exception