org.apache.giraph.examples

Class PageRankWithKryoSimpleWritable

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,PageRankWithKryoSimpleWritable.VertexValue,PageRankWithKryoSimpleWritable.EdgeValue,PageRankWithKryoSimpleWritable.MessageValue>

org.apache.giraph.examples.PageRankWithKryoSimpleWritable

All Implemented Interfaces:

AggregatorUsage, GiraphConfigurationSettable<org.apache.hadoop.io.LongWritable,PageRankWithKryoSimpleWritable.VertexValue,PageRankWithKryoSimpleWritable.EdgeValue>, ImmutableClassesGiraphConfigurable<org.apache.hadoop.io.LongWritable,PageRankWithKryoSimpleWritable.VertexValue,PageRankWithKryoSimpleWritable.EdgeValue>, TypesHolder<org.apache.hadoop.io.LongWritable,PageRankWithKryoSimpleWritable.VertexValue,PageRankWithKryoSimpleWritable.EdgeValue,PageRankWithKryoSimpleWritable.MessageValue,PageRankWithKryoSimpleWritable.MessageValue>, Computation<org.apache.hadoop.io.LongWritable,PageRankWithKryoSimpleWritable.VertexValue,PageRankWithKryoSimpleWritable.EdgeValue,PageRankWithKryoSimpleWritable.MessageValue,PageRankWithKryoSimpleWritable.MessageValue>, WorkerAggregatorUsage, WorkerBroadcastUsage, WorkerGlobalCommUsage, WorkerIndexUsage<org.apache.hadoop.io.LongWritable>, WorkerReduceUsage

public class PageRankWithKryoSimpleWritable
extends BasicComputation<org.apache.hadoop.io.LongWritable,PageRankWithKryoSimpleWritable.VertexValue,PageRankWithKryoSimpleWritable.EdgeValue,PageRankWithKryoSimpleWritable.MessageValue>

Copy of SimplePageRank, modified to test vertex/edge and message values that derives from KryoSimpleWritable.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PageRankWithKryoSimpleWritable.DoubleMaxWrapperAggregator Aggregator for getting max double value
static class	PageRankWithKryoSimpleWritable.DoubleMinWrapperAggregator Aggregator for getting min double value.
static class	PageRankWithKryoSimpleWritable.EdgeValue Creating a custom edge value class to force kryo to register with a new ID.
static class	PageRankWithKryoSimpleWritable.MessageValue Creating a custom message value class to force kryo to register with a new ID.
static class	PageRankWithKryoSimpleWritable.PageRankWithKryoMasterCompute Master compute associated with PageRankWithKryoSimpleWritable.
static class	PageRankWithKryoSimpleWritable.PageRankWithKryoVertexInputFormat VertexInputFormat that supports PageRankWithKryoSimpleWritable
static class	PageRankWithKryoSimpleWritable.PageRankWithKryoVertexReader Simple VertexReader that supports PageRankWithKryoSimpleWritable
static class	PageRankWithKryoSimpleWritable.PageRankWithKryoWorkerContext Worker context used with PageRankWithKryoSimpleWritable.
static class	PageRankWithKryoSimpleWritable.VertexValue Creating a custom vertex value class to force kryo to register with a new ID.

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
PageRankWithKryoSimpleWritable()

Method Summary

Modifier and Type	Method and Description
void	compute(Vertex<org.apache.hadoop.io.LongWritable,PageRankWithKryoSimpleWritable.VertexValue,PageRankWithKryoSimpleWritable.EdgeValue> vertex, Iterable<PageRankWithKryoSimpleWritable.MessageValue> messages) Must be defined by user to do computation on a single Vertex.

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.conf.ImmutableClassesGiraphConfigurable

getConf

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

setConf

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

getBroadcast

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

reduce, reduceMerge

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

aggregate

Methods inherited from interface org.apache.giraph.aggregators.AggregatorUsage

getAggregatedValue

Field Detail

MAX_SUPERSTEPS

public static final int MAX_SUPERSTEPS

Number of supersteps for this test

See Also:

Constant Field Values

Constructor Detail

PageRankWithKryoSimpleWritable

public PageRankWithKryoSimpleWritable()

Method Detail

compute

public void compute(Vertex<org.apache.hadoop.io.LongWritable,PageRankWithKryoSimpleWritable.VertexValue,PageRankWithKryoSimpleWritable.EdgeValue> vertex,
                    Iterable<PageRankWithKryoSimpleWritable.MessageValue> messages)
             throws IOException

Description copied from class: AbstractComputation

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

Specified by:

compute in interface Computation<org.apache.hadoop.io.LongWritable,PageRankWithKryoSimpleWritable.VertexValue,PageRankWithKryoSimpleWritable.EdgeValue,PageRankWithKryoSimpleWritable.MessageValue,PageRankWithKryoSimpleWritable.MessageValue>

Specified by:

compute in class AbstractComputation<org.apache.hadoop.io.LongWritable,PageRankWithKryoSimpleWritable.VertexValue,PageRankWithKryoSimpleWritable.EdgeValue,PageRankWithKryoSimpleWritable.MessageValue,PageRankWithKryoSimpleWritable.MessageValue>

Parameters:

vertex - Vertex

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.

Throws:

IOException