org.apache.giraph.comm.messages

Class InMemoryMessageStoreFactory<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>

java.lang.Object

org.apache.giraph.comm.messages.InMemoryMessageStoreFactory<I,M>

Type Parameters:

I - Vertex id

M - Message data

All Implemented Interfaces:

MessageStoreFactory<I,M,MessageStore<I,M>>

public class InMemoryMessageStoreFactory<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>
extends Object
implements MessageStoreFactory<I,M,MessageStore<I,M>>

Message store factory which produces message stores which hold all messages in memory. Depending on whether or not combiner is currently used, this factory creates OneMessagePerVertexStore or ByteArrayMessagesPerVertexStore

Field Summary

Fields

Modifier and Type	Field and Description
protected ImmutableClassesGiraphConfiguration<I,?,?>	conf Hadoop configuration
protected PartitionSplitInfo<I>	partitionInfo Partition info

Constructor Summary

Constructors

Constructor and Description
InMemoryMessageStoreFactory() Default constructor allowing class invocation via Reflection.

Method Summary

Modifier and Type	Method and Description
void	initialize(PartitionSplitInfo<I> partitionInfo, ImmutableClassesGiraphConfiguration<I,?,?> conf) Implementation class should use this method of initialization of any required internal state.
MessageStore<I,M>	newStore(MessageClasses<I,M> messageClasses) Creates new message store.
protected MessageStore<I,M>	newStoreWithCombiner(Class<M> messageClass, MessageValueFactory<M> messageValueFactory, MessageCombiner<? super I,M> messageCombiner) MessageStore to be used when combiner is enabled
protected MessageStore<I,M>	newStoreWithoutCombiner(Class<M> messageClass, MessageValueFactory<M> messageValueFactory, MessageEncodeAndStoreType encodeAndStore) MessageStore to be used when combiner is not enabled

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

partitionInfo

protected PartitionSplitInfo<I extends org.apache.hadoop.io.WritableComparable> partitionInfo

Partition info

conf

protected ImmutableClassesGiraphConfiguration<I extends org.apache.hadoop.io.WritableComparable,?,?> conf

Hadoop configuration

Constructor Detail

InMemoryMessageStoreFactory

public InMemoryMessageStoreFactory()

Default constructor allowing class invocation via Reflection.

Method Detail

newStoreWithCombiner

protected MessageStore<I,M> newStoreWithCombiner(Class<M> messageClass,
                                                 MessageValueFactory<M> messageValueFactory,
                                                 MessageCombiner<? super I,M> messageCombiner)

MessageStore to be used when combiner is enabled

Parameters:

messageClass - message class

messageValueFactory - message value factory

messageCombiner - message combiner

Returns:

message store

newStoreWithoutCombiner

protected MessageStore<I,M> newStoreWithoutCombiner(Class<M> messageClass,
                                                    MessageValueFactory<M> messageValueFactory,
                                                    MessageEncodeAndStoreType encodeAndStore)

MessageStore to be used when combiner is not enabled

Parameters:

messageClass - message class

messageValueFactory - message value factory

encodeAndStore - message encode and store type

Returns:

message store

newStore

public MessageStore<I,M> newStore(MessageClasses<I,M> messageClasses)

Description copied from interface: MessageStoreFactory

Creates new message store.

Specified by:

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

Parameters:

messageClasses - Message classes information to be held in the store

Returns:

New message store

initialize

public void initialize(PartitionSplitInfo<I> partitionInfo,
                       ImmutableClassesGiraphConfiguration<I,?,?> conf)

Description copied from interface: MessageStoreFactory

Implementation class should use this method of initialization of any required internal state.

Specified by:

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

Parameters:

partitionInfo - Partition split info

conf - Configuration