<FRAG_T extends ImmutableEdgecutFragment,MSG_T> @com.alibaba.fastffi.FFINameAlias("GetMessage") boolean |
DefaultMessageManager.getMessageImmutable(FRAG_T frag,
Vertex<Long> vertex,
MSG_T msg) |
Get the message received for specified vertex during last super step.
|
default <FRAG_T extends ImmutableEdgecutFragment,MSG_T> @com.alibaba.fastffi.FFINameAlias("GetMessage") boolean |
DefaultMessageManagerGen.getMessageImmutable(FRAG_T frag,
Vertex<Long> vertex,
MSG_T msg) |
|
<FRAG_T extends ImmutableEdgecutFragment,MSG_T> void |
DefaultMessageManager.sendMsgThroughEdgesImmutable(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 ImmutableEdgecutFragment,MSG_T> void |
DefaultMessageManagerGen.sendMsgThroughEdgesImmutable(FRAG_T frag,
Vertex<Long> vertex,
MSG_T msg) |
|
<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 |
ParallelMessageManager.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 ImmutableEdgecutFragment<OID_T,VID_T,VDATA_T,EDATA_T>,MSG_T,UNUSED_T> void |
ParallelMessageManagerGen.sendMsgThroughEdgesImmutable(FRAG_T frag,
Vertex<VID_T> vertex,
MSG_T msg,
int channel_id,
UNUSED_T unused) |
|
<FRAG_T extends ImmutableEdgecutFragment,MSG_T> void |
DefaultMessageManager.sendMsgThroughIEdgesImmutable(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 ImmutableEdgecutFragment,MSG_T> void |
DefaultMessageManagerGen.sendMsgThroughIEdgesImmutable(FRAG_T frag,
Vertex<Long> vertex,
MSG_T msg) |
|
<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 |
ParallelMessageManager.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 ImmutableEdgecutFragment<OID_T,VID_T,VDATA_T,EDATA_T>,MSG_T,UNUSED_T> void |
ParallelMessageManagerGen.sendMsgThroughIEdgesImmutable(FRAG_T frag,
Vertex<VID_T> vertex,
MSG_T msg,
int channel_id,
UNUSED_T unused) |
|
<FRAG_T extends ImmutableEdgecutFragment,MSG_T> void |
DefaultMessageManager.sendMsgThroughOEdgesImmutable(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 ImmutableEdgecutFragment,MSG_T> void |
DefaultMessageManagerGen.sendMsgThroughOEdgesImmutable(FRAG_T frag,
Vertex<Long> vertex,
MSG_T msg) |
|
<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 |
ParallelMessageManager.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 <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 |
ParallelMessageManagerGen.sendMsgThroughOEdgesImmutable(FRAG_T frag,
Vertex<VID_T> vertex,
MSG_T msg,
int channel_id,
UNUSED_T unused) |
|
<FRAG_T extends ImmutableEdgecutFragment,MSG_T> void |
DefaultMessageManager.syncStateOnOuterVertexImmutable(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 ImmutableEdgecutFragment,MSG_T> void |
DefaultMessageManagerGen.syncStateOnOuterVertexImmutable(FRAG_T frag,
Vertex<Long> vertex,
MSG_T msg) |
|
<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 |
ParallelMessageManager.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>,MSG_T,UNUSED_T> void |
ParallelMessageManagerGen.syncStateOnOuterVertexImmutable(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 ImmutableEdgecutFragment<OID_T,VID_T,VDATA_T,EDATA_T>,UNUSED_T> void |
ParallelMessageManager.syncStateOnOuterVertexImmutableNoMsg(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>,UNUSED_T> void |
ParallelMessageManagerGen.syncStateOnOuterVertexImmutableNoMsg(FRAG_T frag,
Vertex<VID_T> vertex,
int channel_id,
UNUSED_T vdata) |
|