Name | Description | Type | Package | Framework |
AbstractListPerVertexStore | Abstract Implementation of SimpleMessageStore where multiple messages are stored per vertex as a list | Class | org.apache.giraph.comm.messages | Giraph |
AsyncMessageStoreWrapper | This class decouples message receiving and processing into separate threads thus reducing contention. | Class | org.apache.giraph.comm.messages.queue | Giraph |
ByteArrayMessagesPerVertexStore | stored per vertex as byte backed datastructures. | Class | org.apache.giraph.comm.messages | Giraph |
DiskBackedMessageStore | Message store which separates data by partitions, and submits them to underlying message store. | Class | org.apache.giraph.comm.messages.out_of_core | Giraph |
DiskBackedMessageStoreFactory | Message store factory which persist the messages on the disk. | Class | org.apache.giraph.comm.messages.out_of_core | Giraph |
IdByteArrayMessageStore | Special message store to be used when IDs are primitive and no combiner is Data is backed by primitive maps in order to decrease number of objects and | Class | org.apache.giraph.comm.messages.primitives | Giraph |
IdOneMessagePerVertexStore | Special message store to be used when IDs are primitive and message doesn't need to be, and message combiner is used. | Class | org.apache.giraph.comm.messages.primitives | Giraph |
InMemoryMessageStoreFactory | Message store factory which produces message stores which hold all messages in memory. | Class | org.apache.giraph.comm.messages | Giraph |
IntByteArrayMessageStore | Special message store to be used when ids are IntWritable and no combiner Uses fastutil primitive maps in order to decrease number of objects and | Class | org.apache.giraph.comm.messages.primitives | Giraph |
IntFloatMessageStore | Special message store to be used when ids are IntWritable and messages are FloatWritable and messageCombiner is used. | Class | org.apache.giraph.comm.messages.primitives | Giraph |
LongAbstractListMessageStore | Special message store to be used when ids are LongWritable and no combiner Uses fastutil primitive maps in order to decrease number of objects and | Class | org.apache.giraph.comm.messages.primitives.long_id | Giraph |
LongAbstractMessageStore | Special message store to be used when ids are LongWritable and no combiner Uses fastutil primitive maps in order to decrease number of objects and | Class | org.apache.giraph.comm.messages.primitives.long_id | Giraph |
LongByteArrayMessageStore | Special message store to be used when ids are LongWritable and no combiner Uses fastutil primitive maps in order to decrease number of objects and | Class | org.apache.giraph.comm.messages.primitives.long_id | Giraph |
LongDoubleMessageStore | Special message store to be used when ids are LongWritable and messages are DoubleWritable and messageCombiner is used. | Class | org.apache.giraph.comm.messages.primitives | Giraph |
LongPointerListMessageStore | This stores messages in ExtendedByteArrayOutputBuffer | Class | org.apache.giraph.comm.messages.primitives.long_id | Giraph |
MessageEncodeAndStoreType | enum MessageEncodeAndStoreTypeThere are two types of message-stores currently | Class | org.apache.giraph.comm.messages | Giraph |
MessagesIterable | Class | org.apache.giraph.comm.messages | Giraph | |
MessageStore | Interface | org.apache.giraph.comm.messages | Giraph | |
MessageStoreFactory | Interface | org.apache.giraph.comm.messages | Giraph | |
OneMessagePerVertexStore | message per vertex. | Class | org.apache.giraph.comm.messages | Giraph |
PartitionDiskBackedMessageStore | Message storage with in-memory map of messages and with support for flushing all the messages to the disk. | Class | org.apache.giraph.comm.messages.out_of_core | Giraph |
PartitionMessage | Small wrapper that holds a reference to vertex message and knows partition id. | Class | org.apache.giraph.comm.messages.queue | Giraph |
PointerListMessagesIterable | Class | org.apache.giraph.comm.messages | Giraph | |
PointerListPerVertexStore | stored as a list of long pointers to extended data output objects Used when there is no combiner provided. | Class | org.apache.giraph.comm.messages | Giraph |
SequentialFileMessageStore | Used for writing and reading collection of messages to the disk. | Class | org.apache.giraph.comm.messages.out_of_core | Giraph |
SimpleMessageStore | Abstract class for MessageStore which allows any kind of object to hold messages for one vertex. | Class | org.apache.giraph.comm.messages | Giraph |