<FRAG_T extends ArrowProjectedFragment,MSG_T,SKIP_T> @com.alibaba.fastffi.FFINameAlias("GetMessage") boolean |
DefaultMessageManager.getMessageArrowProjected(FRAG_T frag,
Vertex<Long> vertex,
MSG_T msg,
SKIP_T skip) |
Get the message received for specified vertex during last super step.
|
default <FRAG_T extends ArrowProjectedFragment,MSG_T,SKIP_T> @com.alibaba.fastffi.FFINameAlias("GetMessage") boolean |
DefaultMessageManagerGen.getMessageArrowProjected(FRAG_T frag,
Vertex<Long> vertex,
MSG_T msg,
SKIP_T skip) |
|
<OID_T,VID_T,VDATA_T,EDATA_T,FRAG_T extends ArrowProjectedFragment<OID_T,VID_T,VDATA_T,EDATA_T>,MSG_T,UNUSED_T> @com.alibaba.fastffi.FFINameAlias("GetMessage") boolean |
MessageInBuffer.getMessageArrowProjected(FRAG_T frag,
Vertex<VID_T> vertex,
MSG_T msg,
UNUSED_T unused) |
|
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> @com.alibaba.fastffi.FFINameAlias("GetMessage") boolean |
MessageInBufferGen.getMessageArrowProjected(FRAG_T frag,
Vertex<VID_T> vertex,
MSG_T msg,
UNUSED_T unused) |
|
<FRAG_T extends ArrowProjectedFragment,MSG_T> void |
DefaultMessageManager.sendMsgThroughEdgesArrowProjected(FRAG_T frag,
Vertex<Long> vertex,
MSG_T msg) |
Send the a vertex's data to other fragment through incoming and outgoing edges.
|
default <FRAG_T extends ArrowProjectedFragment,MSG_T> void |
DefaultMessageManagerGen.sendMsgThroughEdgesArrowProjected(FRAG_T frag,
Vertex<Long> vertex,
MSG_T msg) |
|
<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 |
ParallelMessageManager.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 ArrowProjectedFragment<OID_T,VID_T,VDATA_T,EDATA_T>,MSG_T,UNUSED_T> void |
ParallelMessageManagerGen.sendMsgThroughEdgesArrowProjected(FRAG_T frag,
Vertex<VID_T> vertex,
MSG_T msg,
int channel_id,
UNUSED_T unused) |
|
<FRAG_T extends ArrowProjectedFragment,MSG_T> void |
DefaultMessageManager.sendMsgThroughIEdgesArrowProjected(FRAG_T frag,
Vertex<Long> vertex,
MSG_T msg) |
Send the a vertex's data to other fragment through incoming edges.
|
default <FRAG_T extends ArrowProjectedFragment,MSG_T> void |
DefaultMessageManagerGen.sendMsgThroughIEdgesArrowProjected(FRAG_T frag,
Vertex<Long> vertex,
MSG_T msg) |
|
<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 |
ParallelMessageManager.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 ArrowProjectedFragment<OID_T,VID_T,VDATA_T,EDATA_T>,MSG_T,UNUSED_T> void |
ParallelMessageManagerGen.sendMsgThroughIEdgesArrowProjected(FRAG_T frag,
Vertex<VID_T> vertex,
MSG_T msg,
int channel_id,
UNUSED_T unused) |
|
<FRAG_T extends ArrowProjectedFragment,MSG_T> void |
DefaultMessageManager.sendMsgThroughOEdgesArrowProjected(FRAG_T frag,
Vertex<Long> vertex,
MSG_T msg) |
Send the a vertex's data to other fragment through outgoing edges.
|
default <FRAG_T extends ArrowProjectedFragment,MSG_T> void |
DefaultMessageManagerGen.sendMsgThroughOEdgesArrowProjected(FRAG_T frag,
Vertex<Long> vertex,
MSG_T msg) |
|
<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 |
ParallelMessageManager.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 ArrowProjectedFragment<OID_T,VID_T,VDATA_T,EDATA_T>,MSG_T,UNUSED_T> void |
ParallelMessageManagerGen.sendMsgThroughOEdgesArrowProjected(FRAG_T frag,
Vertex<VID_T> vertex,
MSG_T msg,
int channel_id,
UNUSED_T unused) |
|
<FRAG_T extends ArrowProjectedFragment,MSG_T> void |
DefaultMessageManager.syncStateOnOuterVertexArrowProjected(FRAG_T frag,
Vertex<Long> vertex,
MSG_T msg) |
Send a msg to the fragment where the querying outer vertex is an inner vertex.
|
default <FRAG_T extends ArrowProjectedFragment,MSG_T> void |
DefaultMessageManagerGen.syncStateOnOuterVertexArrowProjected(FRAG_T frag,
Vertex<Long> vertex,
MSG_T msg) |
|
<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 |
ParallelMessageManager.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>,MSG_T,UNUSED_T> void |
ParallelMessageManagerGen.syncStateOnOuterVertexArrowProjected(FRAG_T frag,
Vertex<VID_T> vertex,
MSG_T msg,
int channel_id,
UNUSED_T unused) |
|
<OID_T,VID_T,VDATA_T,EDATA_T,FRAG_T extends ArrowProjectedFragment<OID_T,VID_T,VDATA_T,EDATA_T>,UNUSED_T> void |
ParallelMessageManager.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 ArrowProjectedFragment<OID_T,VID_T,VDATA_T,EDATA_T>,UNUSED_T> void |
ParallelMessageManagerGen.syncStateOnOuterVertexArrowProjectedNoMsg(FRAG_T frag,
Vertex<VID_T> vertex,
int channel_id,
UNUSED_T vdata) |
|