Package | Description |
---|---|
org.apache.giraph.block_app.framework.piece |
Single execution object - Piece, and related classes.
|
org.apache.giraph.block_app.framework.piece.messages |
Utility classes for handling of messages within Pieces
|
org.apache.giraph.comm.messages |
Package of classes for storing messages.
|
org.apache.giraph.conf |
Package of Giraph configuration related things.
|
Modifier and Type | Field and Description |
---|---|
static EnumConfOption<MessageEncodeAndStoreType> |
DefaultParentPiece.MESSAGE_ENCODE_AND_STORE_TYPE_MIN_FORCE
This option will tell which message encode & store enum to force,
when combining is not enabled.
|
Modifier and Type | Method and Description |
---|---|
MessageEncodeAndStoreType |
ObjectMessageClasses.getMessageEncodeAndStoreType() |
Constructor and Description |
---|
ObjectMessageClasses(Class<M> messageClass,
SupplierFromConf<MessageValueFactory<M>> messageValueFactorySupplier,
SupplierFromConf<? extends MessageCombiner<? super I,M>> messageCombinerSupplier,
MessageEncodeAndStoreType messageEncodeAndStoreType,
boolean ignoreExistingVertices) |
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.