com.soteradefense.dga.lc

Class LeafCompressionComputation

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.lc.LeafCompressionComputation

All Implemented Interfaces:

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

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

Leaf Compression is an analytic used to compress a graph; nodes on the periphery of the graph that do not show an extensive network of connections from them will inform the nodes connected to them to remove them from the graph

This cycle continues until all leaves have been pruned.

Constructor Summary

Constructors

Constructor and Description
LeafCompressionComputation()

Method Summary

Methods

Modifier and Type	Method and Description
void	compute(Vertex<Text,Text,Text> vertex, Iterable<Text> messages)
void	initialize(GraphState graphState, WorkerClientRequestProcessor<Text,Text,Text> workerClientRequestProcessor, GraphTaskManager<Text,Text,Text> graphTaskManager, WorkerAggregatorUsage workerAggregatorUsage, WorkerContext workerContext)

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

addEdgeRequest, addVertexRequest, addVertexRequest, aggregate, getAggregatedValue, getContext, getSuperstep, getTotalNumEdges, getTotalNumVertices, getWorkerContext, 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

LeafCompressionComputation

public LeafCompressionComputation()

Method Detail

initialize

public void initialize(GraphState graphState,
              WorkerClientRequestProcessor<Text,Text,Text> workerClientRequestProcessor,
              GraphTaskManager<Text,Text,Text> graphTaskManager,
              WorkerAggregatorUsage workerAggregatorUsage,
              WorkerContext workerContext)

Specified by:

initialize in interface Computation<Text,Text,Text,Text,Text>

Overrides:

initialize in class AbstractComputation<Text,Text,Text,Text,Text>

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