I
- Vertex idM
- Message data@NotThreadSafe public class SendOneMessageToManyCache<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable> extends SendMessageCache<I,M>
SendMessageCache.TargetVertexIdIterator<I extends org.apache.hadoop.io.WritableComparable>
clientProcessor, maxMessagesSizePerWorker, messageValueFactory, totalMsgBytesSentInSuperstep, totalMsgsSentInSuperstep
Constructor and Description |
---|
SendOneMessageToManyCache(ImmutableClassesGiraphConfiguration conf,
CentralizedServiceWorker<?,?,?> serviceWorker,
NettyWorkerClientRequestProcessor<I,?,?> processor,
int maxMsgSize)
Constructor
|
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
|
addMessage, addMessage, createVertexIdData, removeWorkerMessages, resetMessageBytesCount, resetMessageCount, sendMessageRequest, sendMessageToAllRequest
addData, addData
getConf, getData, getInitialBufferSize, getNumWorkers, getSendWorkerInitialBufferSize, getServiceWorker, getWorkerPartitions, incrDataSize, removeAllData, removeWorkerData, setData
public SendOneMessageToManyCache(ImmutableClassesGiraphConfiguration conf, CentralizedServiceWorker<?,?,?> serviceWorker, NettyWorkerClientRequestProcessor<I,?,?> processor, int maxMsgSize)
conf
- Giraph configurationserviceWorker
- Service workerprocessor
- NettyWorkerClientRequestProcessormaxMsgSize
- Max message size sent to a workerpublic void sendMessageToAllRequest(Iterator<I> vertexIdIterator, M message)
SendMessageCache
sendMessageToAllRequest
in class SendMessageCache<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>
vertexIdIterator
- The iterator of target vertex idsmessage
- The message sent to a workerpublic void flush()
SendMessageCache
flush
in class SendMessageCache<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable>
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.