Package org.apache.giraph.comm.messages

Package of classes for storing messages.

See: Description

Interface Summary

Interface	Description
MessageStore<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>	Message store
MessageStoreFactory<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable,MS>	Factory for message stores
PartitionSplitInfo<I extends org.apache.hadoop.io.WritableComparable>	Interface providing partition split information.

Class Summary

Class	Description
AbstractListPerVertexStore<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable,L extends List>	Abstract Implementation of SimpleMessageStore where multiple messages are stored per vertex as a list Used when there is no combiner provided.
ByteArrayMessagesPerVertexStore<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>	Implementation of SimpleMessageStore where multiple messages are stored per vertex as byte backed datastructures.
ByteArrayMessagesPerVertexStore.Factory<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>	Factory for ByteArrayMessagesPerVertexStore
InMemoryMessageStoreFactory<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>	Message store factory which produces message stores which hold all messages in memory.
MessagesIterable<M extends org.apache.hadoop.io.Writable>	Special iterable that recycles the message
OneMessagePerVertexStore<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>	Implementation of SimpleMessageStore where we have a single message per vertex.
PointerListMessagesIterable<M extends org.apache.hadoop.io.Writable>	Create an iterable for messages based on a pointer list
PointerListPerVertexStore<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>	Implementation of SimpleMessageStore where multiple messages are stored as a list of long pointers to extended data output objects Used when there is no combiner provided.
SimpleMessageStore<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable,T>	Abstract class for MessageStore which allows any kind of object to hold messages for one vertex.

Enum Summary

Enum	Description
MessageEncodeAndStoreType	There are two types of message-stores currently pointer based, and default byte-array based

Package org.apache.giraph.comm.messages Description

Package of classes for storing messages.