Package | Description |
---|---|
org.apache.giraph.comm.messages |
Package of classes for storing messages.
|
org.apache.giraph.conf |
Package of Giraph configuration related things.
|
Modifier and Type | Method and Description |
---|---|
static MessageEncodeAndStoreType |
MessageEncodeAndStoreType.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static MessageEncodeAndStoreType[] |
MessageEncodeAndStoreType.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
protected MessageStore<I,M> |
InMemoryMessageStoreFactory.newStoreWithoutCombiner(Class<M> messageClass,
MessageValueFactory<M> messageValueFactory,
MessageEncodeAndStoreType encodeAndStore)
MessageStore to be used when combiner is not enabled
|
Modifier and Type | Field and Description |
---|---|
static EnumConfOption<MessageEncodeAndStoreType> |
GiraphConstants.MESSAGE_ENCODE_AND_STORE_TYPE
This option will tell which message encode & store enum to use when
combining is not enabled
|
Modifier and Type | Method and Description |
---|---|
MessageEncodeAndStoreType |
DefaultMessageClasses.getMessageEncodeAndStoreType() |
MessageEncodeAndStoreType |
MessageClasses.getMessageEncodeAndStoreType()
Get MessageEncodeAndStoreType
|
MessageEncodeAndStoreType |
ImmutableClassesGiraphConfiguration.getOutgoingMessageEncodeAndStoreType()
Get outgoing message encode and store type
|
Modifier and Type | Method and Description |
---|---|
void |
DefaultMessageClasses.setMessageEncodeAndStoreType(MessageEncodeAndStoreType messageEncodeAndStoreType) |
Constructor and Description |
---|
DefaultMessageClasses(Class<M> messageClass,
Class<? extends MessageValueFactory<M>> messageValueFactoryClass,
Class<? extends MessageCombiner<? super I,M>> messageCombinerClass,
MessageEncodeAndStoreType messageEncodeAndStoreType)
Constructor
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.