Package com.alibaba.graphscope.parallel
Interface DefaultMessageManagerGen
-
- All Superinterfaces:
DefaultMessageManager
,com.alibaba.fastffi.FFIPointer
,FFIType
,MessageManagerBase
,Serializable
- All Known Implementing Classes:
DefaultMessageManagerGen_cxx_0xb936493c
public interface DefaultMessageManagerGen extends DefaultMessageManager
-
-
Method Summary
All Methods Instance Methods Default Methods Modifier and Type Method Description default <FRAG_T extends ArrowProjectedFragment,MSG_T,SKIP_T>
@com.alibaba.fastffi.FFINameAlias("GetMessage") booleangetMessageArrowProjected(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 ImmutableEdgecutFragment,MSG_T>
@com.alibaba.fastffi.FFINameAlias("GetMessage") booleangetMessageImmutable(FRAG_T frag, Vertex<Long> vertex, MSG_T msg)
Get the message received for specified vertex during last super step.default <MSG_T> @com.alibaba.fastffi.FFINameAlias("GetMessage") boolean
getPureMessage(MSG_T msg)
Get message into target MSG_T.default <FRAG_T extends ArrowProjectedFragment,MSG_T>
voidsendMsgThroughEdgesArrowProjected(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>
voidsendMsgThroughEdgesImmutable(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>
voidsendMsgThroughIEdgesArrowProjected(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>
voidsendMsgThroughIEdgesImmutable(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>
voidsendMsgThroughOEdgesArrowProjected(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>
voidsendMsgThroughOEdgesImmutable(FRAG_T frag, Vertex<Long> vertex, MSG_T msg)
Send the a vertex's data to other fragment through outgoing edges.default <MSG_T> void
sendToFragment(int dst_fid, MSG_T msg)
Send a message to Immutable fragment.default <FRAG_T extends ArrowProjectedFragment,MSG_T>
voidsyncStateOnOuterVertexArrowProjected(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>
voidsyncStateOnOuterVertexImmutable(FRAG_T frag, Vertex<Long> vertex, MSG_T msg)
Send a msg to the fragment where the querying outer vertex is an inner vertex.-
Methods inherited from interface com.alibaba.graphscope.parallel.DefaultMessageManager
getMessage, sendMsgThroughEdges, sendMsgThroughIEdges, sendMsgThroughOEdges, syncStateOnOuterVertex
-
Methods inherited from interface com.alibaba.graphscope.parallel.MessageManagerBase
finishARound, forceContinue, getMsgSize, start, startARound, toTerminate
-
-
-
-
Method Detail
-
sendToFragment
default <MSG_T> void sendToFragment(int dst_fid, MSG_T msg)
Description copied from interface:DefaultMessageManager
Send a message to Immutable fragment.- Specified by:
sendToFragment
in interfaceDefaultMessageManager
- Type Parameters:
MSG_T
- msg typemsg
- msg to send
-
getPureMessage
default <MSG_T> @com.alibaba.fastffi.FFINameAlias("GetMessage") boolean getPureMessage(MSG_T msg)
Description copied from interface:DefaultMessageManager
Get message into target MSG_T.- Specified by:
getPureMessage
in interfaceDefaultMessageManager
- Parameters:
msg
- received msg.- Returns:
-
getMessageImmutable
default <FRAG_T extends ImmutableEdgecutFragment,MSG_T> @com.alibaba.fastffi.FFINameAlias("GetMessage") boolean getMessageImmutable(FRAG_T frag, Vertex<Long> vertex, MSG_T msg)
Description copied from interface:DefaultMessageManager
Get the message received for specified vertex during last super step.- Specified by:
getMessageImmutable
in interfaceDefaultMessageManager
- Type Parameters:
FRAG_T
- frag type.MSG_T
- msg type.- Parameters:
frag
- bound fragment.vertex
- querying vertex.msg
- msg place hold.- Returns:
- true if really got a message.
-
getMessageArrowProjected
default <FRAG_T extends ArrowProjectedFragment,MSG_T,SKIP_T> @com.alibaba.fastffi.FFINameAlias("GetMessage") boolean getMessageArrowProjected(FRAG_T frag, Vertex<Long> vertex, MSG_T msg, SKIP_T skip)
Description copied from interface:DefaultMessageManager
Get the message received for specified vertex during last super step.- Specified by:
getMessageArrowProjected
in interfaceDefaultMessageManager
- Type Parameters:
FRAG_T
- frag type.MSG_T
- msg type.- Parameters:
frag
- bound fragment.vertex
- querying vertex.msg
- msg place hold.- Returns:
- true if really got a message.
-
syncStateOnOuterVertexImmutable
default <FRAG_T extends ImmutableEdgecutFragment,MSG_T> void syncStateOnOuterVertexImmutable(FRAG_T frag, Vertex<Long> vertex, MSG_T msg)
Description copied from interface:DefaultMessageManager
Send a msg to the fragment where the querying outer vertex is an inner vertex.- Specified by:
syncStateOnOuterVertexImmutable
in interfaceDefaultMessageManager
- Type Parameters:
FRAG_T
- fragment type.MSG_T
- message type.- Parameters:
frag
- fragment.vertex
- querying vertex.msg
- msg to send.
-
syncStateOnOuterVertexArrowProjected
default <FRAG_T extends ArrowProjectedFragment,MSG_T> void syncStateOnOuterVertexArrowProjected(FRAG_T frag, Vertex<Long> vertex, MSG_T msg)
Description copied from interface:DefaultMessageManager
Send a msg to the fragment where the querying outer vertex is an inner vertex.- Specified by:
syncStateOnOuterVertexArrowProjected
in interfaceDefaultMessageManager
- Type Parameters:
FRAG_T
- fragment type.MSG_T
- message type.- Parameters:
frag
- fragment.vertex
- querying vertex.msg
- msg to send.
-
sendMsgThroughOEdgesImmutable
default <FRAG_T extends ImmutableEdgecutFragment,MSG_T> void sendMsgThroughOEdgesImmutable(FRAG_T frag, Vertex<Long> vertex, MSG_T msg)
Description copied from interface:DefaultMessageManager
Send the a vertex's data to other fragment through outgoing edges.- Specified by:
sendMsgThroughOEdgesImmutable
in interfaceDefaultMessageManager
- Type Parameters:
FRAG_T
- fragment type.MSG_T
- message type.- Parameters:
frag
- ImmutableEdgeCutFragment.vertex
- querying vertex.msg
- msg to send.
-
sendMsgThroughOEdgesArrowProjected
default <FRAG_T extends ArrowProjectedFragment,MSG_T> void sendMsgThroughOEdgesArrowProjected(FRAG_T frag, Vertex<Long> vertex, MSG_T msg)
Description copied from interface:DefaultMessageManager
Send the a vertex's data to other fragment through outgoing edges.- Specified by:
sendMsgThroughOEdgesArrowProjected
in interfaceDefaultMessageManager
- Type Parameters:
FRAG_T
- fragment type.MSG_T
- message type.- Parameters:
frag
- ArrowProjectedFragment.vertex
- querying vertex.msg
- msg to send.
-
sendMsgThroughIEdgesImmutable
default <FRAG_T extends ImmutableEdgecutFragment,MSG_T> void sendMsgThroughIEdgesImmutable(FRAG_T frag, Vertex<Long> vertex, MSG_T msg)
Description copied from interface:DefaultMessageManager
Send the a vertex's data to other fragment through incoming edges.- Specified by:
sendMsgThroughIEdgesImmutable
in interfaceDefaultMessageManager
- Type Parameters:
FRAG_T
- fragment type.MSG_T
- message type.- Parameters:
frag
- ImmutableEdgecutFragment.vertex
- querying vertex.msg
- msg to send.
-
sendMsgThroughIEdgesArrowProjected
default <FRAG_T extends ArrowProjectedFragment,MSG_T> void sendMsgThroughIEdgesArrowProjected(FRAG_T frag, Vertex<Long> vertex, MSG_T msg)
Description copied from interface:DefaultMessageManager
Send the a vertex's data to other fragment through incoming edges.- Specified by:
sendMsgThroughIEdgesArrowProjected
in interfaceDefaultMessageManager
- Type Parameters:
FRAG_T
- fragment type.MSG_T
- message type.- Parameters:
frag
- ArrowProjectedFragment.vertex
- querying vertex.msg
- msg to send.
-
sendMsgThroughEdgesImmutable
default <FRAG_T extends ImmutableEdgecutFragment,MSG_T> void sendMsgThroughEdgesImmutable(FRAG_T frag, Vertex<Long> vertex, MSG_T msg)
Description copied from interface:DefaultMessageManager
Send the a vertex's data to other fragment through incoming and outgoing edges.- Specified by:
sendMsgThroughEdgesImmutable
in interfaceDefaultMessageManager
- Type Parameters:
FRAG_T
- fragment type.MSG_T
- message type.- Parameters:
frag
- ImmutableEdgeCutFragment.vertex
- querying vertex.msg
- msg to send.
-
sendMsgThroughEdgesArrowProjected
default <FRAG_T extends ArrowProjectedFragment,MSG_T> void sendMsgThroughEdgesArrowProjected(FRAG_T frag, Vertex<Long> vertex, MSG_T msg)
Description copied from interface:DefaultMessageManager
Send the a vertex's data to other fragment through incoming and outgoing edges.- Specified by:
sendMsgThroughEdgesArrowProjected
in interfaceDefaultMessageManager
- Type Parameters:
FRAG_T
- fragment type.MSG_T
- message type.- Parameters:
frag
- ArrowProjectedFragment.vertex
- querying vertex.msg
- msg to send.
-
-