org.apache.giraph.comm.messages

Interface MessageStoreFactory<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable,MS>

Type Parameters:

I - Vertex id

M - Message data

MS - Message store

All Known Implementing Classes:

ByteArrayMessagesPerVertexStore.Factory, InMemoryMessageStoreFactory

public interface MessageStoreFactory<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable,MS>

Factory for message stores

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.
MS	newStore(MessageClasses<I,M> messageClasses) Creates new message store.

Method Detail

newStore

MS newStore(MessageClasses<I,M> messageClasses)

Creates new message store.

Parameters:

messageClasses - Message classes information to be held in the store

Returns:

New message store

initialize

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

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

Parameters:

partitionInfo - Partition split info

conf - Configuration