Interface MessageStoreFactory<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable,MS>
-
- Type Parameters:
I
- Vertex idM
- Message dataMS
- Message store
- All Known Implementing Classes:
DefaultMessageStoreFactory
public interface MessageStoreFactory<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable,MS>
Factory for message stores
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
initialize(IFragment fragment, ImmutableClassesGiraphConfiguration<I,?,?> conf)
Implementation class should use this method of initialization of any required internal state.MS
newStore(org.apache.giraph.conf.MessageClasses<I,M> messageClasses)
Creates new message store.
-
-
-
Method Detail
-
newStore
MS newStore(org.apache.giraph.conf.MessageClasses<I,M> messageClasses)
Creates new message store.- Parameters:
messageClasses
- Message classes information to be held in the store- Returns:
- New message store
-
initialize
void initialize(IFragment fragment, ImmutableClassesGiraphConfiguration<I,?,?> conf)
Implementation class should use this method of initialization of any required internal state.- Parameters:
fragment
- fragment used for partition queryingconf
- Configuration
-
-