Package com.alibaba.graphscope.parallel.mm.impl

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 long	THRESHOLD

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

Modifier and Type	Method	Description
void	finishMessageSending()	Make sure all messages has been sent.
void	postApplication()
void	postSuperstep()
void	preSuperstep()
void	receiveMessages()	Called by our frame work, to deserialize the messages from c++ to java.
void	sendMessage(OID_T dstOid, OUT_MSG_T message)	Send one message to dstOid.
void	sendMessageToAllEdges(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

Methods inherited from class java.lang.Object

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

Field Detail

THRESHOLD

public static long THRESHOLD

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()