org.apache.giraph.block_app.framework.piece.messages

Class ObjectMessageClasses<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>

java.lang.Object

org.apache.giraph.writable.kryo.KryoWritable

org.apache.giraph.block_app.framework.piece.messages.ObjectMessageClasses<I,M>

Type Parameters:

I - Vertex id type

M - Message type

All Implemented Interfaces:

MessageClasses<I,M>, KryoIgnoreWritable, org.apache.hadoop.io.Writable

public class ObjectMessageClasses<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>
extends KryoWritable
implements MessageClasses<I,M>

MessageClasses implementation that provides factory and combiner instances through a provided supplier.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
MessageClasses<I,M>	createCopyForNewSuperstep()
MessageCombiner<? super I,M>	createMessageCombiner(ImmutableClassesGiraphConfiguration<I,? extends org.apache.hadoop.io.Writable,? extends org.apache.hadoop.io.Writable> conf)
MessageValueFactory<M>	createMessageValueFactory(ImmutableClassesGiraphConfiguration conf)
Class<M>	getMessageClass()
MessageEncodeAndStoreType	getMessageEncodeAndStoreType()
boolean	ignoreExistingVertices()
boolean	useMessageCombiner()
void	verifyConsistent(ImmutableClassesGiraphConfiguration conf)

Methods inherited from class org.apache.giraph.writable.kryo.KryoWritable

readFields, write

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

readFields, write

Constructor Detail

ObjectMessageClasses

public ObjectMessageClasses()

ObjectMessageClasses

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

Method Detail

getMessageClass

public Class<M> getMessageClass()

Specified by:

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

createMessageValueFactory

public MessageValueFactory<M> createMessageValueFactory(ImmutableClassesGiraphConfiguration conf)

Specified by:

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

createMessageCombiner

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

Specified by:

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

useMessageCombiner

public boolean useMessageCombiner()

Specified by:

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

ignoreExistingVertices

public boolean ignoreExistingVertices()

Specified by:

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

getMessageEncodeAndStoreType

public MessageEncodeAndStoreType getMessageEncodeAndStoreType()

Specified by:

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

createCopyForNewSuperstep

public MessageClasses<I,M> createCopyForNewSuperstep()

Specified by:

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

verifyConsistent

public void verifyConsistent(ImmutableClassesGiraphConfiguration conf)

Specified by:

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