I
- Vertex idM
- Message datapublic class InMemoryMessageStoreFactory<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable> extends Object implements MessageStoreFactory<I,M,MessageStore<I,M>>
OneMessagePerVertexStore
or
ByteArrayMessagesPerVertexStore
Modifier and Type | Field and Description |
---|---|
protected ImmutableClassesGiraphConfiguration<I,?,?> |
conf
Hadoop configuration
|
protected PartitionSplitInfo<I> |
partitionInfo
Partition info
|
Constructor and Description |
---|
InMemoryMessageStoreFactory()
Default constructor allowing class invocation via Reflection.
|
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.
|
MessageStore<I,M> |
newStore(MessageClasses<I,M> messageClasses)
Creates new message store.
|
protected MessageStore<I,M> |
newStoreWithCombiner(Class<M> messageClass,
MessageValueFactory<M> messageValueFactory,
MessageCombiner<? super I,M> messageCombiner)
MessageStore to be used when combiner is enabled
|
protected MessageStore<I,M> |
newStoreWithoutCombiner(Class<M> messageClass,
MessageValueFactory<M> messageValueFactory,
MessageEncodeAndStoreType encodeAndStore)
MessageStore to be used when combiner is not enabled
|
protected PartitionSplitInfo<I extends org.apache.hadoop.io.WritableComparable> partitionInfo
protected ImmutableClassesGiraphConfiguration<I extends org.apache.hadoop.io.WritableComparable,?,?> conf
public InMemoryMessageStoreFactory()
protected MessageStore<I,M> newStoreWithCombiner(Class<M> messageClass, MessageValueFactory<M> messageValueFactory, MessageCombiner<? super I,M> messageCombiner)
messageClass
- message classmessageValueFactory
- message value factorymessageCombiner
- message combinerprotected MessageStore<I,M> newStoreWithoutCombiner(Class<M> messageClass, MessageValueFactory<M> messageValueFactory, MessageEncodeAndStoreType encodeAndStore)
messageClass
- message classmessageValueFactory
- message value factoryencodeAndStore
- message encode and store typepublic MessageStore<I,M> newStore(MessageClasses<I,M> messageClasses)
MessageStoreFactory
newStore
in interface MessageStoreFactory<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable,MessageStore<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>>
messageClasses
- Message classes information to be held in the storepublic void initialize(PartitionSplitInfo<I> partitionInfo, ImmutableClassesGiraphConfiguration<I,?,?> conf)
MessageStoreFactory
initialize
in interface MessageStoreFactory<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable,MessageStore<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>>
partitionInfo
- Partition split infoconf
- ConfigurationCopyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.