Interface MessageStoreFactory<I extends org.apache.hadoop.io.WritableComparable,​M extends org.apache.hadoop.io.Writable,​MS>

  • Type Parameters:
    I - Vertex id
    M - Message data
    MS - 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 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 querying
        conf - Configuration