All Superinterfaces:

com.alibaba.fastffi.FFIPointer, FFIType, MessageManagerBase, ParallelMessageManager, Serializable

All Known Implementing Classes:

ParallelMessageManagerGen_cxx_0x5a835738
```
public interface ParallelMessageManagerGen
extends ParallelMessageManager
```

Method Summary

All Methods Instance Methods Default Methods
Modifier and Type	Method	Description
`default <OID_T,VID_T,VDATA_T,EDATA_T,FRAG_T extends ArrowProjectedFragment<OID_T,VID_T,VDATA_T,EDATA_T>,MSG_T,UNUSED_T> void`	`sendMsgThroughEdgesArrowProjected(FRAG_T frag, Vertex<VID_T> vertex, MSG_T msg, int channel_id, UNUSED_T unused)`	Send the a vertex's data to other fragment through incoming and outgoing edges.
`default <OID_T,VID_T,VDATA_T,EDATA_T,FRAG_T extends ImmutableEdgecutFragment<OID_T,VID_T,VDATA_T,EDATA_T>,MSG_T,UNUSED_T> void`	`sendMsgThroughEdgesImmutable(FRAG_T frag, Vertex<VID_T> vertex, MSG_T msg, int channel_id, UNUSED_T unused)`	Send the a vertex's data to other fragment through incoming and outgoing edges.
`default <OID_T,VID_T,VDATA_T,EDATA_T,FRAG_T extends ArrowProjectedFragment<OID_T,VID_T,VDATA_T,EDATA_T>,MSG_T,UNUSED_T> void`	`sendMsgThroughIEdgesArrowProjected(FRAG_T frag, Vertex<VID_T> vertex, MSG_T msg, int channel_id, UNUSED_T unused)`	Send the a vertex's data to other fragment through incoming edges.
`default <OID_T,VID_T,VDATA_T,EDATA_T,FRAG_T extends ImmutableEdgecutFragment<OID_T,VID_T,VDATA_T,EDATA_T>,MSG_T,UNUSED_T> void`	`sendMsgThroughIEdgesImmutable(FRAG_T frag, Vertex<VID_T> vertex, MSG_T msg, int channel_id, UNUSED_T unused)`	Send the a vertex's data to other fragment through incoming edges.
`default <OID_T,VID_T,VDATA_T,EDATA_T,FRAG_T extends ArrowProjectedFragment<OID_T,VID_T,VDATA_T,EDATA_T>,MSG_T,UNUSED_T> void`	`sendMsgThroughOEdgesArrowProjected(FRAG_T frag, Vertex<VID_T> vertex, MSG_T msg, int channel_id, UNUSED_T unused)`	Send the a vertex's data to other fragment through outgoing edges.
`default <OID_T,VID_T,VDATA_T,EDATA_T,FRAG_T extends ImmutableEdgecutFragment<OID_T,VID_T,VDATA_T,EDATA_T>,MSG_T,UNUSED_T> void`	`sendMsgThroughOEdgesImmutable(FRAG_T frag, Vertex<VID_T> vertex, MSG_T msg, int channel_id, UNUSED_T unused)`	Send the a vertex's data to other fragment through outgoing edges.
`default <MSG_T> void`	`sendToFragment(int dstFid, MSG_T msg, int channelId)`
`default <OID_T,VID_T,VDATA_T,EDATA_T,FRAG_T extends ArrowProjectedFragment<OID_T,VID_T,VDATA_T,EDATA_T>,MSG_T,UNUSED_T> void`	`syncStateOnOuterVertexArrowProjected(FRAG_T frag, Vertex<VID_T> vertex, MSG_T msg, int channel_id, UNUSED_T unused)`	Send a msg to the fragment where the querying outer vertex is an inner vertexin another fragment.
`default <OID_T,VID_T,VDATA_T,EDATA_T,FRAG_T extends ArrowProjectedFragment<OID_T,VID_T,VDATA_T,EDATA_T>,UNUSED_T> void`	`syncStateOnOuterVertexArrowProjectedNoMsg(FRAG_T frag, Vertex<VID_T> vertex, int channel_id, UNUSED_T vdata)`	SyncState on outer vertex without message, used in bfs etc.
`default <OID_T,VID_T,VDATA_T,EDATA_T,FRAG_T extends ImmutableEdgecutFragment<OID_T,VID_T,VDATA_T,EDATA_T>,MSG_T,UNUSED_T> void`	`syncStateOnOuterVertexImmutable(FRAG_T frag, Vertex<VID_T> vertex, MSG_T msg, int channel_id, UNUSED_T unused)`	Send a msg to the fragment where the querying outer vertex is an inner vertexin another fragment.
`default <OID_T,VID_T,VDATA_T,EDATA_T,FRAG_T extends ImmutableEdgecutFragment<OID_T,VID_T,VDATA_T,EDATA_T>,UNUSED_T> void`	`syncStateOnOuterVertexImmutableNoMsg(FRAG_T frag, Vertex<VID_T> vertex, int channel_id, UNUSED_T vdata)`	SyncState on outer vertex without message, used in bfs etc.

Methods inherited from interface com.alibaba.fastffi.FFIPointer
getAddress

Methods inherited from interface com.alibaba.graphscope.parallel.MessageManagerBase
finishARound, forceContinue, getMsgSize, start, startARound, toTerminate

Methods inherited from interface com.alibaba.graphscope.parallel.ParallelMessageManager
getMessageInBuffer, initChannels, parallelProcess, sendMsgThroughEdges, sendMsgThroughIEdges, sendMsgThroughOEdges, syncStateOnOuterVertex, syncStateOnOuterVertexNoMsg

Method Detail

sendToFragment

default <MSG_T> void sendToFragment(int dstFid,
                                    MSG_T msg,
                                    int channelId)

Specified by:: sendToFragment in interface ParallelMessageManager