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 | 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 | Description |
---|---|
MessageEncodeAndStoreType |
There are two types of message-stores currently
pointer based, and default byte-array based
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.