org.apache.giraph.conf

Interface MessageClasses<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>

Type Parameters:

I -

M -

All Superinterfaces:

org.apache.hadoop.io.Writable

All Known Implementing Classes:

DefaultMessageClasses, ObjectMessageClasses

public interface MessageClasses<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>
extends org.apache.hadoop.io.Writable

Interface for containing all items that define message being sent, including it's value factory and combiner.

Method Summary

Modifier and Type	Method and Description
MessageClasses<I,M>	createCopyForNewSuperstep() Creates a fresh copy of this object, to be used and changed for new superstep.
MessageCombiner<? super I,M>	createMessageCombiner(ImmutableClassesGiraphConfiguration<I,? extends org.apache.hadoop.io.Writable,? extends org.apache.hadoop.io.Writable> conf) Create new instance of MessageCombiner
MessageValueFactory<M>	createMessageValueFactory(ImmutableClassesGiraphConfiguration conf) Create new instance of MessageValueFactory
Class<M>	getMessageClass() Get message class
MessageEncodeAndStoreType	getMessageEncodeAndStoreType() Get MessageEncodeAndStoreType
boolean	ignoreExistingVertices() Whether to completely ignore existing vertices, and just process messages
boolean	useMessageCombiner() Has message combiner been specified
void	verifyConsistent(ImmutableClassesGiraphConfiguration conf) Verify if types are internally consistent

Methods inherited from interface org.apache.hadoop.io.Writable

readFields, write

Method Detail

getMessageClass

Class<M> getMessageClass()

Get message class

Returns:

message class

createMessageValueFactory

MessageValueFactory<M> createMessageValueFactory(ImmutableClassesGiraphConfiguration conf)

Create new instance of MessageValueFactory

Parameters:

conf - Configuration

Returns:

message value factory

createMessageCombiner

MessageCombiner<? super I,M> createMessageCombiner(ImmutableClassesGiraphConfiguration<I,? extends org.apache.hadoop.io.Writable,? extends org.apache.hadoop.io.Writable> conf)

Create new instance of MessageCombiner

Parameters:

conf - Configuration

Returns:

message combiner

useMessageCombiner

boolean useMessageCombiner()

Has message combiner been specified

Returns:

has message combiner been specified

getMessageEncodeAndStoreType

MessageEncodeAndStoreType getMessageEncodeAndStoreType()

Get MessageEncodeAndStoreType

Returns:

message encode and store type

createCopyForNewSuperstep

MessageClasses<I,M> createCopyForNewSuperstep()

Creates a fresh copy of this object, to be used and changed for new superstep. (that should be independent from the previous one)

Returns:

message classes

verifyConsistent

void verifyConsistent(ImmutableClassesGiraphConfiguration conf)

Verify if types are internally consistent

Parameters:

conf - Configuration

ignoreExistingVertices

boolean ignoreExistingVertices()

Whether to completely ignore existing vertices, and just process messages

Returns:

ignoreExistingVertices