org.apache.giraph.examples

Class VerifyMessage.VerifyMessageVertex

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.IntWritable,org.apache.hadoop.io.FloatWritable,VerifyMessage.VerifiableMessage>

org.apache.giraph.examples.VerifyMessage.VerifyMessageVertex

All Implemented Interfaces:

AggregatorUsage, ImmutableClassesGiraphConfigurable<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.FloatWritable,VerifyMessage.VerifiableMessage>, WorkerAggregatorUsage

Enclosing class:

VerifyMessage

public static class VerifyMessage.VerifyMessageVertex
extends Vertex<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.FloatWritable,VerifyMessage.VerifiableMessage>

Send and verify messages.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	VerifyMessage.VerifyMessageVertex.VerifyMessageVertexWorkerContext Worker context used with VerifyMessage.VerifyMessageVertex.

Field Summary

Fields

Modifier and Type	Field and Description
static String	SUPERSTEP_COUNT Dynamically set number of SUPERSTEPS

Constructor Summary

Constructors

Constructor and Description
VerifyMessage.VerifyMessageVertex()

Method Summary

Methods

Modifier and Type	Method and Description
void	compute(Iterable<VerifyMessage.VerifiableMessage> messages) Must be defined by user to do computation on a single Vertex.
static long	getFinalSum()

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

SUPERSTEP_COUNT

public static final String SUPERSTEP_COUNT

Dynamically set number of SUPERSTEPS

See Also:

Constant Field Values

Constructor Detail

VerifyMessage.VerifyMessageVertex

public VerifyMessage.VerifyMessageVertex()

Method Detail

getFinalSum

public static long getFinalSum()

compute

public void compute(Iterable<VerifyMessage.VerifiableMessage> 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.IntWritable,org.apache.hadoop.io.FloatWritable,VerifyMessage.VerifiableMessage>

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.