org.apache.giraph.comm.messages.primitives.long_id

Class LongAbstractListStore<M extends org.apache.hadoop.io.Writable,L extends List>

java.lang.Object

org.apache.giraph.comm.messages.primitives.long_id.LongAbstractStore<M,L>

org.apache.giraph.comm.messages.primitives.long_id.LongAbstractListStore<M,L>

Type Parameters:

M - message type

L - list type

All Implemented Interfaces:

MessageStore<org.apache.hadoop.io.LongWritable,M>

Direct Known Subclasses:

LongPointerListPerVertexStore

public abstract class LongAbstractListStore<M extends org.apache.hadoop.io.Writable,L extends List>
extends LongAbstractStore<M,L>

Special message store to be used when ids are LongWritable and no combiner is used. Uses fastutil primitive maps in order to decrease number of objects and get better performance.

Field Summary

Fields inherited from class org.apache.giraph.comm.messages.primitives.long_id.LongAbstractStore

config, map, messageValueFactory, partitionInfo

Constructor Summary

Constructors

Constructor and Description
LongAbstractListStore(MessageValueFactory<M> messageValueFactory, PartitionSplitInfo<org.apache.hadoop.io.LongWritable> partitionInfo, ImmutableClassesGiraphConfiguration<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable> config) Constructor

Method Summary

Modifier and Type	Method and Description
protected abstract L	createList() Create an instance of L
void	finalizeStore() Called before start of computation in bspworker Since it is run from a single thread while the store is not being accessed by any other thread - this is ensured to be thread-safe
protected L	getList(org.apache.hadoop.io.LongWritable vertexId) Get list for the current vertexId
boolean	hasMessagesForVertex(org.apache.hadoop.io.LongWritable vertexId) Check if we have messages for some vertex

Methods inherited from class org.apache.giraph.comm.messages.primitives.long_id.LongAbstractStore

clearAll, clearPartition, clearVertexMessages, getPartitionDestinationVertices, getPartitionMap, hasMessagesForPartition

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, getVertexMessages, isPointerListEncoding, readFieldsForPartition, writePartition

Constructor Detail

LongAbstractListStore

public LongAbstractListStore(MessageValueFactory<M> messageValueFactory,
                             PartitionSplitInfo<org.apache.hadoop.io.LongWritable> partitionInfo,
                             ImmutableClassesGiraphConfiguration<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable> config)

Constructor

Parameters:

messageValueFactory - Factory for creating message values

partitionInfo - Partition split info

config - Hadoop configuration

Method Detail

createList

protected abstract L createList()

Create an instance of L

Returns:

instance of L

getList

protected L getList(org.apache.hadoop.io.LongWritable vertexId)

Get list for the current vertexId

Parameters:

vertexId - vertex id

Returns:

list for current vertexId

finalizeStore

public void finalizeStore()

Description copied from interface: MessageStore

Called before start of computation in bspworker Since it is run from a single thread while the store is not being accessed by any other thread - this is ensured to be thread-safe

hasMessagesForVertex

public boolean hasMessagesForVertex(org.apache.hadoop.io.LongWritable vertexId)

Description copied from interface: MessageStore

Check if we have messages for some vertex

Specified by:

hasMessagesForVertex in interface MessageStore<org.apache.hadoop.io.LongWritable,M extends org.apache.hadoop.io.Writable>

Overrides:

hasMessagesForVertex in class LongAbstractStore<M extends org.apache.hadoop.io.Writable,L extends List>

Parameters:

vertexId - Id of vertex which we want to check

Returns:

True iff we have messages for vertex with required id