org.apache.giraph.benchmark

Class RandomMessageBenchmark.RandomMessageVertex

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.DoubleWritable,org.apache.hadoop.io.BytesWritable>

org.apache.giraph.benchmark.RandomMessageBenchmark.RandomMessageVertex

All Implemented Interfaces:

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

Enclosing class:

RandomMessageBenchmark

public static class RandomMessageBenchmark.RandomMessageVertex
extends Vertex<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.DoubleWritable,org.apache.hadoop.io.BytesWritable>

Actual message computation (messaging in this case)

Constructor Summary

Constructors

Constructor and Description
RandomMessageBenchmark.RandomMessageVertex()

Method Summary

Methods

Modifier and Type	Method and Description
void	compute(Iterable<org.apache.hadoop.io.BytesWritable> 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

Constructor Detail

RandomMessageBenchmark.RandomMessageVertex

public RandomMessageBenchmark.RandomMessageVertex()

Method Detail

compute

public void compute(Iterable<org.apache.hadoop.io.BytesWritable> 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.DoubleWritable,org.apache.hadoop.io.BytesWritable>

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.