Package org.apache.giraph.comm.messages.queue

Package for message store queue, that decouples netty threads from threads processing messages.

See: Description

Class Summary

Class	Description
AsyncMessageStoreWrapper<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>	This class decouples message receiving and processing into separate threads thus reducing contention.
PartitionMessage<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>	Small wrapper that holds a reference to vertex message and knows partition id.

Package org.apache.giraph.comm.messages.queue Description

Package for message store queue, that decouples netty threads from threads processing messages.