Uses of Interface
org.apache.giraph.conf.MessageClasses

Packages that use MessageClasses

Package	Description
org.apache.giraph.block_app.framework.internal	Implementation of execution logic, guiding internal execution of Block Application.
org.apache.giraph.block_app.framework.piece	Single execution object - Piece, and related classes.
org.apache.giraph.block_app.framework.piece.delegate	Pieces that delegate their work to a set of one or multiple other Pieces.
org.apache.giraph.block_app.framework.piece.messages	Utility classes for handling of messages within Pieces
org.apache.giraph.block_app.migration	Migration utility for transforming standard Giraph applications, into Block Applications.
org.apache.giraph.comm.messages	Package of classes for storing messages.
org.apache.giraph.conf	Package of Giraph configuration related things.
org.apache.giraph.master	Package of all the master related things.

Uses of MessageClasses in org.apache.giraph.block_app.framework.internal

Methods in org.apache.giraph.block_app.framework.internal that return MessageClasses

Modifier and Type	Method and Description
MessageClasses	BlockWorkerPieces.getOutgoingMessageClasses(ImmutableClassesGiraphConfiguration conf)

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

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

Modifier and Type	Method and Description
MessageClasses<I,M>	DefaultParentPiece.getMessageClasses(ImmutableClassesGiraphConfiguration conf)
abstract MessageClasses<I,M>	AbstractPiece.getMessageClasses(ImmutableClassesGiraphConfiguration conf) Returns MessageClasses definition for messages being sent by this Piece.

Uses of MessageClasses in org.apache.giraph.block_app.framework.piece.delegate

Methods in org.apache.giraph.block_app.framework.piece.delegate that return MessageClasses

Modifier and Type	Method and Description
MessageClasses<I,M>	DelegatePiece.getMessageClasses(ImmutableClassesGiraphConfiguration conf)

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

Classes in org.apache.giraph.block_app.framework.piece.messages that implement MessageClasses

Modifier and Type	Class and Description
class	ObjectMessageClasses<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable> MessageClasses implementation that provides factory and combiner instances through a provided supplier.

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

Modifier and Type	Method and Description
MessageClasses<I,M>	ObjectMessageClasses.createCopyForNewSuperstep()

Uses of MessageClasses in org.apache.giraph.block_app.migration

Methods in org.apache.giraph.block_app.migration that return MessageClasses

Modifier and Type	Method and Description
MessageClasses<I,M>	MigrationPiece.getMessageClasses(ImmutableClassesGiraphConfiguration conf)

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

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

Modifier and Type	Method and Description
MessageStore<I,M>	InMemoryMessageStoreFactory.newStore(MessageClasses<I,M> messageClasses)
MessageStore<I,M>	ByteArrayMessagesPerVertexStore.Factory.newStore(MessageClasses<I,M> messageClasses)
MS	MessageStoreFactory.newStore(MessageClasses<I,M> messageClasses) Creates new message store.

Uses of MessageClasses in org.apache.giraph.conf

Classes in org.apache.giraph.conf that implement MessageClasses

Modifier and Type	Class and Description
class	DefaultMessageClasses<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable> Default implementation of MessageClasses

Fields in org.apache.giraph.conf declared as MessageClasses

Modifier and Type	Field and Description
protected MessageClasses<I,? extends org.apache.hadoop.io.Writable>	GiraphClasses.incomingMessageClasses Incoming message classes
protected MessageClasses<I,? extends org.apache.hadoop.io.Writable>	GiraphClasses.outgoingMessageClasses Outgoing message classes

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

Modifier and Type	Method and Description
MessageClasses<I,M>	DefaultMessageClasses.createCopyForNewSuperstep()
MessageClasses<I,M>	MessageClasses.createCopyForNewSuperstep() Creates a fresh copy of this object, to be used and changed for new superstep.
MessageClasses<? extends org.apache.hadoop.io.WritableComparable,? extends org.apache.hadoop.io.Writable>	GiraphClasses.getIncomingMessageClasses()
<M extends org.apache.hadoop.io.Writable> MessageClasses<I,M>	ImmutableClassesGiraphConfiguration.getIncomingMessageClasses() Get incoming message classes
MessageClasses<? extends org.apache.hadoop.io.WritableComparable,? extends org.apache.hadoop.io.Writable>	GiraphClasses.getOutgoingMessageClasses()
<M extends org.apache.hadoop.io.Writable> MessageClasses<I,M>	ImmutableClassesGiraphConfiguration.getOutgoingMessageClasses() Get outgoing message classes

Methods in org.apache.giraph.conf with parameters of type MessageClasses

Modifier and Type	Method and Description
GiraphClasses	GiraphClasses.setIncomingMessageClasses(MessageClasses<I,? extends org.apache.hadoop.io.Writable> incomingMessageClasses) Set incoming Message Value class held - messages which have been sent in the previous superstep and are processed in the current one
GiraphClasses	GiraphClasses.setOutgoingMessageClasses(MessageClasses<I,? extends org.apache.hadoop.io.Writable> outgoingMessageClasses) Set outgoing Message Value class held - messages which are going to be sent during current superstep

Uses of MessageClasses in org.apache.giraph.master

Methods in org.apache.giraph.master that return MessageClasses

Modifier and Type	Method and Description
MessageClasses<? extends org.apache.hadoop.io.WritableComparable,? extends org.apache.hadoop.io.Writable>	SuperstepClasses.getOutgoingMessageClasses()

Methods in org.apache.giraph.master with parameters of type MessageClasses

Modifier and Type	Method and Description
void	SuperstepClasses.setOutgoingMessageClasses(MessageClasses<? extends org.apache.hadoop.io.WritableComparable,? extends org.apache.hadoop.io.Writable> outgoingMessageClasses) Set's outgoing MessageClasses for next superstep.
void	MasterCompute.setOutgoingMessageClasses(MessageClasses<? extends org.apache.hadoop.io.WritableComparable,? extends org.apache.hadoop.io.Writable> outgoingMessageClasses) Set outgoing message classes to be used

Constructors in org.apache.giraph.master with parameters of type MessageClasses

Constructor and Description
SuperstepClasses(ImmutableClassesGiraphConfiguration conf, Class<? extends Computation> computationClass, MessageClasses<? extends org.apache.hadoop.io.WritableComparable,? extends org.apache.hadoop.io.Writable> incomingMessageClasses, MessageClasses<? extends org.apache.hadoop.io.WritableComparable,? extends org.apache.hadoop.io.Writable> outgoingMessageClasses) Constructor
SuperstepClasses(ImmutableClassesGiraphConfiguration conf, Class<? extends Computation> computationClass, MessageClasses<? extends org.apache.hadoop.io.WritableComparable,? extends org.apache.hadoop.io.Writable> incomingMessageClasses, MessageClasses<? extends org.apache.hadoop.io.WritableComparable,? extends org.apache.hadoop.io.Writable> outgoingMessageClasses) Constructor