org.apache.giraph.comm

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

java.lang.Object

org.apache.giraph.comm.SendDataCache<B>

org.apache.giraph.comm.SendVertexIdDataCache<I,M,VertexIdMessages<I,M>>

org.apache.giraph.comm.SendMessageCache<I,M>

org.apache.giraph.comm.SendOneMessageToManyCache<I,M>

Type Parameters:

I - Vertex id

M - Message data

@NotThreadSafe
public class SendOneMessageToManyCache<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>
extends SendMessageCache<I,M>

Aggregates the messages to be sent to workers so they can be sent in bulk.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.giraph.comm.SendMessageCache

SendMessageCache.TargetVertexIdIterator<I extends org.apache.hadoop.io.WritableComparable>

Field Summary

Fields inherited from class org.apache.giraph.comm.SendMessageCache

clientProcessor, maxMessagesSizePerWorker, messageValueFactory, totalMsgBytesSentInSuperstep, totalMsgsSentInSuperstep

Constructor Summary

Constructors

Constructor and Description
SendOneMessageToManyCache(ImmutableClassesGiraphConfiguration conf, CentralizedServiceWorker<?,?,?> serviceWorker, NettyWorkerClientRequestProcessor<I,?,?> processor, int maxMsgSize) Constructor

Method Summary

Modifier and Type	Method and Description
void	flush() Flush the rest of the messages to the workers.
void	sendMessageToAllRequest(Iterator<I> vertexIdIterator, M message) Send message to the target ids in the iterator

Methods inherited from class org.apache.giraph.comm.SendMessageCache

addMessage, addMessage, createVertexIdData, removeWorkerMessages, resetMessageBytesCount, resetMessageCount, sendMessageRequest, sendMessageToAllRequest

Methods inherited from class org.apache.giraph.comm.SendVertexIdDataCache

addData, addData

Methods inherited from class org.apache.giraph.comm.SendDataCache

getConf, getData, getInitialBufferSize, getNumWorkers, getSendWorkerInitialBufferSize, getServiceWorker, getWorkerPartitions, incrDataSize, removeAllData, removeWorkerData, setData

Methods inherited from class java.lang.Object

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

Constructor Detail

SendOneMessageToManyCache

public SendOneMessageToManyCache(ImmutableClassesGiraphConfiguration conf,
                                 CentralizedServiceWorker<?,?,?> serviceWorker,
                                 NettyWorkerClientRequestProcessor<I,?,?> processor,
                                 int maxMsgSize)

Constructor

Parameters:

conf - Giraph configuration

serviceWorker - Service worker

processor - NettyWorkerClientRequestProcessor

maxMsgSize - Max message size sent to a worker

Method Detail

sendMessageToAllRequest

public void sendMessageToAllRequest(Iterator<I> vertexIdIterator,
                                    M message)

Description copied from class: SendMessageCache

Send message to the target ids in the iterator

Overrides:

sendMessageToAllRequest in class SendMessageCache<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>

Parameters:

vertexIdIterator - The iterator of target vertex ids

message - The message sent to a worker

flush

public void flush()

Description copied from class: SendMessageCache

Flush the rest of the messages to the workers.

Overrides:

flush in class SendMessageCache<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>