Uses of Interface
org.apache.giraph.combiner.MessageCombiner

Packages that use MessageCombiner

Package	Description
org.apache.giraph.combiner	Package of Combiners.
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.conf	Package of Giraph configuration related things.
org.apache.giraph.jython	Jython integration.
org.apache.giraph.master	Package of all the master related things.

Uses of MessageCombiner in org.apache.giraph.combiner

Classes in org.apache.giraph.combiner that implement MessageCombiner

Modifier and Type	Class and Description
class	DoubleSumMessageCombiner Deprecated.
class	FloatSumMessageCombiner Deprecated.
class	MaxMessageCombiner<M extends org.apache.hadoop.io.WritableComparable> Message combiner which calculates max of all messages.
class	MinimumDoubleMessageCombiner MessageCombiner which finds the minimum of DoubleWritable.
class	MinimumIntMessageCombiner MessageCombiner that finds the minimum IntWritable
class	MinMessageCombiner<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable> Keeps only the message with minimum value.
class	NullMessageCombiner Keeps only one NullMessage.
class	SimpleSumMessageCombiner Deprecated.
class	SumMessageCombiner<M extends org.apache.hadoop.io.Writable> Message combiner which sums all messages.

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

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

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

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

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

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

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

Constructor and Description
IdOneMessagePerVertexStore(MessageValueFactory<M> messageValueFactory, PartitionSplitInfo<I> partitionInfo, MessageCombiner<? super I,M> messageCombiner, ImmutableClassesGiraphConfiguration<I,?,?> config) Constructor
IntFloatMessageStore(PartitionSplitInfo<org.apache.hadoop.io.IntWritable> partitionInfo, MessageCombiner<? super org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.FloatWritable> messageCombiner) Constructor
LongDoubleMessageStore(PartitionSplitInfo<org.apache.hadoop.io.LongWritable> partitionInfo, MessageCombiner<? super org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable> messageCombiner) Constructor

Uses of MessageCombiner in org.apache.giraph.conf

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

Modifier and Type	Field and Description
static ClassConfOption<MessageCombiner>	GiraphConstants.MESSAGE_COMBINER_CLASS Message combiner class - optional

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

Modifier and Type	Method and Description
MessageCombiner<? super I,M>	DefaultMessageClasses.createMessageCombiner(ImmutableClassesGiraphConfiguration conf)
MessageCombiner<? super I,M>	MessageClasses.createMessageCombiner(ImmutableClassesGiraphConfiguration<I,? extends org.apache.hadoop.io.Writable,? extends org.apache.hadoop.io.Writable> conf) Create new instance of MessageCombiner
<M extends org.apache.hadoop.io.Writable> MessageCombiner<? super I,M>	ImmutableClassesGiraphConfiguration.createOutgoingMessageCombiner() Create a user combiner class

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

Modifier and Type	Method and Description
void	DefaultMessageClasses.setMessageCombinerClass(Class<? extends MessageCombiner<? super I,M>> messageCombinerClass)
void	GiraphConfiguration.setMessageCombinerClass(Class<? extends MessageCombiner> messageCombinerClass) Set the message combiner class (optional)
void	ImmutableClassesGiraphConfiguration.setMessageCombinerClass(Class<? extends MessageCombiner> messageCombinerClass)

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

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

Uses of MessageCombiner in org.apache.giraph.jython

Methods in org.apache.giraph.jython that return types with arguments of type MessageCombiner

Modifier and Type	Method and Description
Class<? extends MessageCombiner>	JythonJob.getMessageCombiner()

Method parameters in org.apache.giraph.jython with type arguments of type MessageCombiner

Modifier and Type	Method and Description
void	JythonJob.setMessageCombiner(Class<? extends MessageCombiner> messageCombiner)

Uses of MessageCombiner in org.apache.giraph.master

Methods in org.apache.giraph.master that return types with arguments of type MessageCombiner

Modifier and Type	Method and Description
Class<? extends MessageCombiner>	MasterCompute.getMessageCombiner() Get MessageCombiner class to be used
Class<? extends MessageCombiner>	SuperstepClasses.getMessageCombinerClass() Get message combiner class

Method parameters in org.apache.giraph.master with type arguments of type MessageCombiner

Modifier and Type	Method and Description
void	MasterCompute.setMessageCombiner(Class<? extends MessageCombiner> combinerClass) Set MessageCombiner class to be used
void	SuperstepClasses.setMessageCombinerClass(Class<? extends MessageCombiner> messageCombinerClass) Set message combiner class.