Class GiraphMpiMessageManager<OID_T extends org.apache.hadoop.io.WritableComparable,VDATA_T extends org.apache.hadoop.io.Writable,EDATA_T extends org.apache.hadoop.io.Writable,IN_MSG_T extends org.apache.hadoop.io.Writable,OUT_MSG_T extends org.apache.hadoop.io.Writable,GS_VID_T,GS_OID_T>
- java.lang.Object
-
- com.alibaba.graphscope.parallel.mm.impl.AbstractMessageManager<OID_T,VDATA_T,EDATA_T,IN_MSG_T,OUT_MSG_T,GS_VID_T,GS_OID_T>
-
- com.alibaba.graphscope.parallel.mm.impl.GiraphMpiMessageManager<OID_T,VDATA_T,EDATA_T,IN_MSG_T,OUT_MSG_T,GS_VID_T,GS_OID_T>
-
- All Implemented Interfaces:
GiraphMessageManager<OID_T,VDATA_T,EDATA_T,IN_MSG_T,OUT_MSG_T,GS_VID_T,GS_OID_T>
public class GiraphMpiMessageManager<OID_T extends org.apache.hadoop.io.WritableComparable,VDATA_T extends org.apache.hadoop.io.Writable,EDATA_T extends org.apache.hadoop.io.Writable,IN_MSG_T extends org.apache.hadoop.io.Writable,OUT_MSG_T extends org.apache.hadoop.io.Writable,GS_VID_T,GS_OID_T> extends AbstractMessageManager<OID_T,VDATA_T,EDATA_T,IN_MSG_T,OUT_MSG_T,GS_VID_T,GS_OID_T>
-
-
Field Summary
Fields Modifier and Type Field Description static longTHRESHOLD-
Fields inherited from class com.alibaba.graphscope.parallel.mm.impl.AbstractMessageManager
currentIncomingMessageStore, fragId, fragment, fragNum, grapeMessager, grapeVertex, nextIncomingMessageStore
-
-
Constructor Summary
Constructors Constructor Description GiraphMpiMessageManager(IFragment fragment, DefaultMessageManager defaultMessageManager, ImmutableClassesGiraphConfiguration configuration, FFICommunicator communicator, GiraphVertexIdManager<GS_VID_T,OID_T> idManager)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidfinishMessageSending()Make sure all messages has been sent.voidpostApplication()voidpostSuperstep()voidpreSuperstep()voidreceiveMessages()Called by our frame work, to deserialize the messages from c++ to java.voidsendMessage(OID_T dstOid, OUT_MSG_T message)Send one message to dstOid.voidsendMessageToAllEdges(org.apache.giraph.graph.Vertex<OID_T,VDATA_T,EDATA_T> vertex, OUT_MSG_T message)Send message to neighbor vertices.-
Methods inherited from class com.alibaba.graphscope.parallel.mm.impl.AbstractMessageManager
anyMessageReceived, checkLid, forceContinue, getCommunicator, getConf, getFragment, getMessages, messageAvailable
-
-
-
-
Constructor Detail
-
GiraphMpiMessageManager
public GiraphMpiMessageManager(IFragment fragment, DefaultMessageManager defaultMessageManager, ImmutableClassesGiraphConfiguration configuration, FFICommunicator communicator, GiraphVertexIdManager<GS_VID_T,OID_T> idManager)
-
-
Method Detail
-
receiveMessages
public void receiveMessages()
Called by our frame work, to deserialize the messages from c++ to java. Must be called before getMessages
-
sendMessage
public void sendMessage(OID_T dstOid, OUT_MSG_T message)
Send one message to dstOid.- Parameters:
dstOid- vertex to receive this message.message- message.
-
sendMessageToAllEdges
public void sendMessageToAllEdges(org.apache.giraph.graph.Vertex<OID_T,VDATA_T,EDATA_T> vertex, OUT_MSG_T message)
Send message to neighbor vertices.- Parameters:
vertex-message- message to send.
-
finishMessageSending
public void finishMessageSending()
Make sure all messages has been sent. Clean outputstream buffer
-
preSuperstep
public void preSuperstep()
-
postSuperstep
public void postSuperstep()
-
postApplication
public void postApplication()
-
-