org.apache.giraph.comm.messages

Class AbstractListPerVertexStore<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable,L extends List>

java.lang.Object

org.apache.giraph.comm.messages.SimpleMessageStore<I,M,L>

org.apache.giraph.comm.messages.AbstractListPerVertexStore<I,M,L>

Type Parameters:

I - Vertex id

M - Message data

L - List type

All Implemented Interfaces:

MessageStore<I,M>

Direct Known Subclasses:

PointerListPerVertexStore

public abstract class AbstractListPerVertexStore<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable,L extends List>
extends SimpleMessageStore<I,M,L>

Abstract Implementation of SimpleMessageStore where multiple messages are stored per vertex as a list Used when there is no combiner provided.

Field Summary

Fields inherited from class org.apache.giraph.comm.messages.SimpleMessageStore

config, map, messageValueFactory, partitionInfo

Constructor Summary

Constructors

Constructor and Description
AbstractListPerVertexStore(MessageValueFactory<M> messageValueFactory, PartitionSplitInfo<I> partitionInfo, ImmutableClassesGiraphConfiguration<I,?,?> config) Constructor

Method Summary

Modifier and Type	Method and Description
protected abstract L	createList() Create an instance of L
protected L	getOrCreateList(I vertexId) Get the list of pointers for a vertex Each pointer has information of how to access an encoded message for this vertex This method will take ownership of the vertex id from the iterator if necessary (when used in the partition map entry)
protected L	getOrCreateList(VertexIdIterator<I> iterator) Get the list of pointers for a vertex Each pointer has information of how to access an encoded message for this vertex
Iterable<M>	getVertexMessages(I vertexId) Gets messages for a vertex.

Methods inherited from class org.apache.giraph.comm.messages.SimpleMessageStore

clearAll, clearPartition, clearVertexMessages, finalizeStore, getMessagesAsIterable, getNumberOfMessagesIn, getOrCreatePartitionMap, getPartitionDestinationVertices, getPartitionId, hasMessagesForPartition, hasMessagesForVertex, readFieldsForMessages, readFieldsForPartition, writeMessages, writePartition

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.comm.messages.MessageStore

addMessage, addPartitionMessages, isPointerListEncoding

Constructor Detail

AbstractListPerVertexStore

public AbstractListPerVertexStore(MessageValueFactory<M> messageValueFactory,
                                  PartitionSplitInfo<I> partitionInfo,
                                  ImmutableClassesGiraphConfiguration<I,?,?> config)

Constructor

Parameters:

messageValueFactory - Message class held in the store

partitionInfo - Partition split info

config - Hadoop configuration

Method Detail

createList

protected abstract L createList()

Create an instance of L

Returns:

instance of L

getOrCreateList

protected L getOrCreateList(VertexIdIterator<I> iterator)

Get the list of pointers for a vertex Each pointer has information of how to access an encoded message for this vertex

Parameters:

iterator - vertex id iterator

Returns:

pointer list

getOrCreateList

protected L getOrCreateList(I vertexId)

Get the list of pointers for a vertex Each pointer has information of how to access an encoded message for this vertex This method will take ownership of the vertex id from the iterator if necessary (when used in the partition map entry)

Parameters:

vertexId - vertex id

Returns:

pointer list

getVertexMessages

public Iterable<M> getVertexMessages(I vertexId)

Description copied from interface: MessageStore

Gets messages for a vertex. The lifetime of every message is only guaranteed until the iterator's next() method is called. Do not hold references to objects returned by this iterator.

Specified by:

getVertexMessages in interface MessageStore<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>

Overrides:

getVertexMessages in class SimpleMessageStore<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable,L extends List>

Parameters:

vertexId - Vertex id for which we want to get messages

Returns:

Iterable of messages for a vertex id