org.apache.giraph.examples

Class SimplePageRankVertex

java.lang.Object

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

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

org.apache.giraph.examples.SimplePageRankVertex

All Implemented Interfaces:

AggregatorUsage, ImmutableClassesGiraphConfigurable<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable,org.apache.hadoop.io.DoubleWritable>, WorkerAggregatorUsage

public class SimplePageRankVertex
extends Vertex<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable,org.apache.hadoop.io.DoubleWritable>

Demonstrates the basic Pregel PageRank implementation.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SimplePageRankVertex.SimplePageRankVertexInputFormat Simple VertexInputFormat that supports SimplePageRankVertex
static class	SimplePageRankVertex.SimplePageRankVertexMasterCompute Master compute associated with SimplePageRankVertex.
static class	SimplePageRankVertex.SimplePageRankVertexOutputFormat Simple VertexOutputFormat that supports SimplePageRankVertex
static class	SimplePageRankVertex.SimplePageRankVertexReader Simple VertexReader that supports SimplePageRankVertex
static class	SimplePageRankVertex.SimplePageRankVertexWorkerContext Worker context used with SimplePageRankVertex.

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
SimplePageRankVertex()

Method Summary

Methods

Modifier and Type	Method and Description
void	compute(Iterable<org.apache.hadoop.io.DoubleWritable> messages) Must be defined by user to do computation on a single Vertex.

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

addEdge, addEdgeRequest, addVertexRequest, addVertexRequest, aggregate, getAggregatedValue, getAllEdgeValues, getContext, getEdges, getEdgeValue, getId, getMutableEdges, getNumEdges, getPartitionContext, getSuperstep, getTotalNumEdges, getTotalNumVertices, getValue, getWorkerContext, initialize, initialize, isHalted, removeEdges, removeEdgesRequest, removeVertexRequest, sendMessage, sendMessageToAllEdges, setEdges, setEdgeValue, setGraphState, setValue, toString, unwrapMutableEdges, voteToHalt, wakeUp

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, wait, wait, wait

Field Detail

MAX_SUPERSTEPS

public static final int MAX_SUPERSTEPS

Number of supersteps for this test

See Also:

Constant Field Values

Constructor Detail

SimplePageRankVertex

public SimplePageRankVertex()

Method Detail

compute

public void compute(Iterable<org.apache.hadoop.io.DoubleWritable> messages)

Description copied from class: Vertex

Must be defined by user to do computation on a single Vertex.

Specified by:

compute in class Vertex<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.FloatWritable,org.apache.hadoop.io.DoubleWritable>

Parameters:

messages - Messages that were sent to this vertex in the previous superstep. Each message is only guaranteed to have a life expectancy as long as next() is not called.