org.apache.giraph.comm.messages

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

java.lang.Object

org.apache.giraph.comm.messages.ByteArrayMessagesPerVertexStore.Factory<I,M>

Type Parameters:

I - Vertex id

M - Message data

All Implemented Interfaces:

MessageStoreFactory<I,M,MessageStore<I,M>>

Enclosing class:

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

public static class ByteArrayMessagesPerVertexStore.Factory<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>
extends Object
implements MessageStoreFactory<I,M,MessageStore<I,M>>

Factory for ByteArrayMessagesPerVertexStore

Constructor Summary

Constructors

Constructor and Description
Factory() Constructor for reflection
Factory(PartitionSplitInfo<I> partitionInfo, ImmutableClassesGiraphConfiguration<I,?,?> config)

Method Summary

Modifier and Type	Method and Description
void	initialize(PartitionSplitInfo<I> partitionInfo, ImmutableClassesGiraphConfiguration<I,?,?> conf) Implementation class should use this method of initialization of any required internal state.
MessageStore<I,M>	newStore(MessageClasses<I,M> messageClasses) Creates new message store.

Methods inherited from class java.lang.Object

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

Constructor Detail

Factory

public Factory()

Constructor for reflection

Factory

public Factory(PartitionSplitInfo<I> partitionInfo,
               ImmutableClassesGiraphConfiguration<I,?,?> config)

Parameters:

partitionInfo - Partition split info

config - Hadoop configuration

Method Detail

newStore

public MessageStore<I,M> newStore(MessageClasses<I,M> messageClasses)

Description copied from interface: MessageStoreFactory

Creates new message store.

Specified by:

newStore in interface MessageStoreFactory<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable,MessageStore<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>>

Parameters:

messageClasses - Message classes information to be held in the store

Returns:

New message store

initialize

public void initialize(PartitionSplitInfo<I> partitionInfo,
                       ImmutableClassesGiraphConfiguration<I,?,?> conf)

Description copied from interface: MessageStoreFactory

Implementation class should use this method of initialization of any required internal state.

Specified by:

initialize in interface MessageStoreFactory<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable,MessageStore<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>>

Parameters:

partitionInfo - Partition split info

conf - Configuration