com.soteradefense.dga.wcc

Class WeaklyConnectedComponentComputation

java.lang.Object

org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable<I,V,E>

org.apache.giraph.graph.AbstractComputation<I,V,E,M,M>

org.apache.giraph.graph.BasicComputation<Text,Text,Text,Text>

com.soteradefense.dga.wcc.WeaklyConnectedComponentComputation

All Implemented Interfaces:

AggregatorUsage, ImmutableClassesGiraphConfigurable<Text,Text,Text>, TypesHolder<Text,Text,Text,Text,Text>, Computation<Text,Text,Text,Text,Text>, WorkerAggregatorUsage

public class WeaklyConnectedComponentComputation
extends BasicComputation<Text,Text,Text,Text>

WeaklyConnectedComponents is the concept of finding how many uniquely connected nodes there are in a specific data set.

Constructor Summary

Constructors

Constructor and Description
WeaklyConnectedComponentComputation()

Method Summary

Methods

Modifier and Type	Method and Description
void	compute(Vertex<Text,Text,Text> vertex, Iterable<Text> messages)

Methods inherited from class org.apache.giraph.graph.AbstractComputation

addEdgeRequest, addVertexRequest, addVertexRequest, aggregate, getAggregatedValue, getContext, getSuperstep, getTotalNumEdges, getTotalNumVertices, getWorkerContext, initialize, postSuperstep, preSuperstep, removeEdgesRequest, removeVertexRequest, sendMessage, sendMessageToAllEdges, sendMessageToMultipleEdges

Methods inherited from class org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable

getConf, setConf

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.giraph.conf.ImmutableClassesGiraphConfigurable

getConf, setConf

Constructor Detail

WeaklyConnectedComponentComputation

public WeaklyConnectedComponentComputation()

Method Detail

compute

public void compute(Vertex<Text,Text,Text> vertex,
           Iterable<Text> messages)
             throws IOException

Specified by:

compute in interface Computation<Text,Text,Text,Text,Text>

Specified by:

compute in class AbstractComputation<Text,Text,Text,Text,Text>

Throws:

IOException