Uses of Interface
org.apache.giraph.factories.MessageValueFactory

Packages that use MessageValueFactory

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	Package of communication related objects, IPC service.
org.apache.giraph.comm.messages	Package of classes for storing messages.
org.apache.giraph.comm.messages.primitives	Package of message stores specialized for a certain type of vertex ids, messages and combiner.
org.apache.giraph.comm.messages.primitives.long_id	Message store based off of primitives when I = LongWritable
org.apache.giraph.conf	Package of Giraph configuration related things.
org.apache.giraph.factories	Package of factories for creating types, for example the user's graph types.
org.apache.giraph.jython.factories	Jython factories.
org.apache.giraph.utils	Package of all generic utility classes.

Uses of MessageValueFactory in org.apache.giraph.block_app.framework.piece

Methods in org.apache.giraph.block_app.framework.piece that return MessageValueFactory

Modifier and Type	Method and Description
protected MessageValueFactory<M>	DefaultParentPiece.getMessageFactory(ImmutableClassesGiraphConfiguration conf) Override to specify message value factory to be used, which creates objects into which messages will be deserialized.

Uses of MessageValueFactory in org.apache.giraph.block_app.framework.piece.messages

Methods in org.apache.giraph.block_app.framework.piece.messages that return MessageValueFactory

Modifier and Type	Method and Description
MessageValueFactory<M>	SupplierFromConf.DefaultMessageFactorySupplierFromConf.apply(ImmutableClassesGiraphConfiguration conf)
MessageValueFactory<M>	ObjectMessageClasses.createMessageValueFactory(ImmutableClassesGiraphConfiguration conf)

Constructor parameters in org.apache.giraph.block_app.framework.piece.messages with type arguments of type MessageValueFactory

Constructor and Description
ObjectMessageClasses(Class<M> messageClass, SupplierFromConf<MessageValueFactory<M>> messageValueFactorySupplier, SupplierFromConf<? extends MessageCombiner<? super I,M>> messageCombinerSupplier, MessageEncodeAndStoreType messageEncodeAndStoreType, boolean ignoreExistingVertices)

Uses of MessageValueFactory in org.apache.giraph.comm

Fields in org.apache.giraph.comm declared as MessageValueFactory

Modifier and Type	Field and Description
protected MessageValueFactory<M>	SendMessageCache.messageValueFactory Cached message value factory

Uses of MessageValueFactory in org.apache.giraph.comm.messages

Fields in org.apache.giraph.comm.messages declared as MessageValueFactory

Modifier and Type	Field and Description
protected MessageValueFactory<M>	SimpleMessageStore.messageValueFactory Message class

Methods in org.apache.giraph.comm.messages with parameters of type MessageValueFactory

Modifier and Type	Method and Description
protected MessageStore<I,M>	InMemoryMessageStoreFactory.newStoreWithCombiner(Class<M> messageClass, MessageValueFactory<M> messageValueFactory, MessageCombiner<? super I,M> messageCombiner) MessageStore to be used when combiner is enabled
protected MessageStore<I,M>	InMemoryMessageStoreFactory.newStoreWithoutCombiner(Class<M> messageClass, MessageValueFactory<M> messageValueFactory, MessageEncodeAndStoreType encodeAndStore) MessageStore to be used when combiner is not enabled

Constructors in org.apache.giraph.comm.messages with parameters of type MessageValueFactory

Constructor and Description
AbstractListPerVertexStore(MessageValueFactory<M> messageValueFactory, PartitionSplitInfo<I> partitionInfo, ImmutableClassesGiraphConfiguration<I,?,?> config) Constructor
ByteArrayMessagesPerVertexStore(MessageValueFactory<M> messageValueFactory, PartitionSplitInfo<I> partitionInfo, ImmutableClassesGiraphConfiguration<I,?,?> config) Constructor
MessagesIterable(Factory<? extends ExtendedDataInput> dataInputFactory, MessageValueFactory<M> messageValueFactory) Constructor
OneMessagePerVertexStore(MessageValueFactory<M> messageValueFactory, PartitionSplitInfo<I> partitionInfo, MessageCombiner<? super I,M> messageCombiner, ImmutableClassesGiraphConfiguration<I,?,?> config)
PointerListMessagesIterable(MessageValueFactory<M> messageValueFactory, it.unimi.dsi.fastutil.longs.LongArrayList pointers, ExtendedByteArrayOutputBuffer msgBuffer)
PointerListPerVertexStore(MessageValueFactory<M> messageValueFactory, PartitionSplitInfo<I> partitionInfo, ImmutableClassesGiraphConfiguration<I,?,?> config) Constructor
SimpleMessageStore(MessageValueFactory<M> messageValueFactory, PartitionSplitInfo<I> partitionInfo, ImmutableClassesGiraphConfiguration<I,?,?> config) Constructor

Uses of MessageValueFactory in org.apache.giraph.comm.messages.primitives

Fields in org.apache.giraph.comm.messages.primitives declared as MessageValueFactory

Modifier and Type	Field and Description
protected MessageValueFactory<M>	IdByteArrayMessageStore.messageValueFactory Message value factory

Constructors in org.apache.giraph.comm.messages.primitives with parameters of type MessageValueFactory

Constructor and Description
IdByteArrayMessageStore(MessageValueFactory<M> messageValueFactory, PartitionSplitInfo<I> partitionInfo, ImmutableClassesGiraphConfiguration<I,?,?> config) Constructor
IdOneMessagePerVertexStore(MessageValueFactory<M> messageValueFactory, PartitionSplitInfo<I> partitionInfo, MessageCombiner<? super I,M> messageCombiner, ImmutableClassesGiraphConfiguration<I,?,?> config) Constructor

Uses of MessageValueFactory in org.apache.giraph.comm.messages.primitives.long_id

Fields in org.apache.giraph.comm.messages.primitives.long_id declared as MessageValueFactory

Modifier and Type	Field and Description
protected MessageValueFactory<M>	LongAbstractStore.messageValueFactory Message value factory

Constructors in org.apache.giraph.comm.messages.primitives.long_id with parameters of type MessageValueFactory

Constructor and Description
LongAbstractListStore(MessageValueFactory<M> messageValueFactory, PartitionSplitInfo<org.apache.hadoop.io.LongWritable> partitionInfo, ImmutableClassesGiraphConfiguration<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable> config) Constructor
LongAbstractStore(MessageValueFactory<M> messageValueFactory, PartitionSplitInfo<org.apache.hadoop.io.LongWritable> partitionInfo, ImmutableClassesGiraphConfiguration<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable> config) Constructor
LongPointerListPerVertexStore(MessageValueFactory<M> messageValueFactory, PartitionSplitInfo<org.apache.hadoop.io.LongWritable> partitionInfo, ImmutableClassesGiraphConfiguration<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Writable,org.apache.hadoop.io.Writable> config) Constructor

Uses of MessageValueFactory in org.apache.giraph.conf

Fields in org.apache.giraph.conf with type parameters of type MessageValueFactory

Modifier and Type	Field and Description
static ClassConfOption<MessageValueFactory>	GiraphConstants.OUTGOING_MESSAGE_VALUE_FACTORY_CLASS Outgoing message value factory class - optional

Methods in org.apache.giraph.conf that return MessageValueFactory

Modifier and Type	Method and Description
<M extends org.apache.hadoop.io.Writable> MessageValueFactory<M>	ImmutableClassesGiraphConfiguration.createIncomingMessageValueFactory() Create new incoming message value factory
MessageValueFactory<M>	DefaultMessageClasses.createMessageValueFactory(ImmutableClassesGiraphConfiguration conf)
MessageValueFactory<M>	MessageClasses.createMessageValueFactory(ImmutableClassesGiraphConfiguration conf) Create new instance of MessageValueFactory
<M extends org.apache.hadoop.io.Writable> MessageValueFactory<M>	ImmutableClassesGiraphConfiguration.createOutgoingMessageValueFactory() Create new outgoing message value factory

Method parameters in org.apache.giraph.conf with type arguments of type MessageValueFactory

Modifier and Type	Method and Description
void	DefaultMessageClasses.setMessageValueFactoryClass(Class<? extends MessageValueFactory<M>> messageValueFactoryClass)

Constructor parameters in org.apache.giraph.conf with type arguments of type MessageValueFactory

Constructor and Description
DefaultMessageClasses(Class<M> messageClass, Class<? extends MessageValueFactory<M>> messageValueFactoryClass, Class<? extends MessageCombiner<? super I,M>> messageCombinerClass, MessageEncodeAndStoreType messageEncodeAndStoreType) Constructor

Uses of MessageValueFactory in org.apache.giraph.factories

Classes in org.apache.giraph.factories that implement MessageValueFactory

Modifier and Type	Class and Description
class	DefaultMessageValueFactory<M extends org.apache.hadoop.io.Writable> Factory class to create default message values.
class	TestMessageValueFactory<M extends org.apache.hadoop.io.Writable> Message Factory class that allows setting the message value class

Uses of MessageValueFactory in org.apache.giraph.jython.factories

Classes in org.apache.giraph.jython.factories that implement MessageValueFactory

Modifier and Type	Class and Description
class	JythonMessageValueFactory<M extends org.apache.hadoop.io.Writable> MessageValueFactory that creates message values which are Jython classes.
class	JythonOutgoingMessageValueFactory<M extends org.apache.hadoop.io.Writable> MessageValueFactory that creates outgoing message values which are Jython classes.

Uses of MessageValueFactory in org.apache.giraph.utils

Constructors in org.apache.giraph.utils with parameters of type MessageValueFactory

Constructor and Description
ByteArrayOneMessageToManyIds(MessageValueFactory<M> messageValueFactory) Constructor.
ByteArrayVertexIdMessages(MessageValueFactory<M> messageValueFactory) Constructor