Package org.apache.wayang.giraph.Algorithm

Class PageRankAlgorithm

java.lang.Object

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

org.apache.giraph.worker.WorkerAggregatorDelegator<I,V,E>

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

org.apache.giraph.graph.BasicComputation<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable,org.apache.hadoop.io.DoubleWritable>

org.apache.wayang.giraph.Algorithm.PageRankAlgorithm

All Implemented Interfaces:

org.apache.giraph.aggregators.AggregatorUsage, org.apache.giraph.conf.GiraphConfigurationSettable<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable>, org.apache.giraph.conf.ImmutableClassesGiraphConfigurable<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable>, org.apache.giraph.conf.TypesHolder<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.DoubleWritable>, org.apache.giraph.graph.Computation<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.DoubleWritable>, org.apache.giraph.worker.WorkerAggregatorUsage, org.apache.giraph.worker.WorkerBroadcastUsage, org.apache.giraph.worker.WorkerGlobalCommUsage, org.apache.giraph.worker.WorkerIndexUsage<org.apache.hadoop.io.LongWritable>, org.apache.giraph.worker.WorkerReduceUsage

public class PageRankAlgorithm
extends org.apache.giraph.graph.BasicComputation<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable,org.apache.hadoop.io.DoubleWritable>

Basic PageRank implementation.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PageRankAlgorithm.PageRankMasterCompute	Master compute associated with PageRankAlgorithm.
static class	PageRankAlgorithm.PageRankVertexInputFormat	Simple VertexInputFormat that supports PageRankAlgorithm
static class	PageRankAlgorithm.PageRankVertexOutputFormat	Simple VertexOutputFormat that supports PageRankAlgorithm
static class	PageRankAlgorithm.PageRankVertexReader	Simple VertexReader that supports PageRankAlgorithm
static class	PageRankAlgorithm.PageRankWorkerContext	Worker context used with PageRankAlgorithm.

Field Summary

Fields

Modifier and Type	Field	Description
static final int	MAX_SUPERSTEPS	Number of supersteps for this test
int	maxSupersteps

Constructor Summary

Constructors

Constructor	Description
PageRankAlgorithm()

Method Summary

Modifier and Type	Method	Description
void	compute(org.apache.giraph.graph.Vertex<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable> vertex, Iterable<org.apache.hadoop.io.DoubleWritable> messages)

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

addEdgeRequest, addVertexRequest, addVertexRequest, getContext, getMyWorkerIndex, getSuperstep, getTotalNumEdges, getTotalNumVertices, getWorkerContext, getWorkerCount, getWorkerForVertex, initialize, postSuperstep, preSuperstep, removeEdgesRequest, removeVertexRequest, sendMessage, sendMessageToAllEdges, sendMessageToMultipleEdges

Methods inherited from class org.apache.giraph.worker.WorkerAggregatorDelegator

aggregate, getAggregatedValue, getBroadcast, reduce, reduceMerge, setWorkerGlobalCommUsage

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.aggregators.AggregatorUsage

getAggregatedValue

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

setConf

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

getConf

Methods inherited from interface org.apache.giraph.worker.WorkerAggregatorUsage

aggregate

Methods inherited from interface org.apache.giraph.worker.WorkerBroadcastUsage

getBroadcast

Methods inherited from interface org.apache.giraph.worker.WorkerReduceUsage

reduce, reduceMerge

Field Details

MAX_SUPERSTEPS

public static final int MAX_SUPERSTEPS

Number of supersteps for this test

See Also:

• Constant Field Values

maxSupersteps

public int maxSupersteps

Constructor Details

PageRankAlgorithm

public PageRankAlgorithm()

Method Details

compute

public void compute(org.apache.giraph.graph.Vertex<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable> vertex,
 Iterable<org.apache.hadoop.io.DoubleWritable> messages)
             throws IOException

Specified by:

compute in interface org.apache.giraph.graph.Computation<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.DoubleWritable>

Specified by:

compute in class org.apache.giraph.graph.AbstractComputation<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.DoubleWritable>

Throws:

IOException