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 voidinitialize(IFragment fragment, ImmutableClassesGiraphConfiguration<I,?,?> conf)Implementation class should use this method of initialization of any required internal state.MSnewStore(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
-
-