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") booleangetPureMessage(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> voidsendToFragment(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:DefaultMessageManagerSend a message to Immutable fragment.- Specified by:
sendToFragmentin 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:DefaultMessageManagerGet message into target MSG_T.- Specified by:
getPureMessagein 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:DefaultMessageManagerGet the message received for specified vertex during last super step.- Specified by:
getMessageImmutablein 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:DefaultMessageManagerGet the message received for specified vertex during last super step.- Specified by:
getMessageArrowProjectedin 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:DefaultMessageManagerSend a msg to the fragment where the querying outer vertex is an inner vertex.- Specified by:
syncStateOnOuterVertexImmutablein 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:DefaultMessageManagerSend a msg to the fragment where the querying outer vertex is an inner vertex.- Specified by:
syncStateOnOuterVertexArrowProjectedin 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:DefaultMessageManagerSend the a vertex's data to other fragment through outgoing edges.- Specified by:
sendMsgThroughOEdgesImmutablein 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:DefaultMessageManagerSend the a vertex's data to other fragment through outgoing edges.- Specified by:
sendMsgThroughOEdgesArrowProjectedin 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:DefaultMessageManagerSend the a vertex's data to other fragment through incoming edges.- Specified by:
sendMsgThroughIEdgesImmutablein 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:DefaultMessageManagerSend the a vertex's data to other fragment through incoming edges.- Specified by:
sendMsgThroughIEdgesArrowProjectedin 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:DefaultMessageManagerSend the a vertex's data to other fragment through incoming and outgoing edges.- Specified by:
sendMsgThroughEdgesImmutablein 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:DefaultMessageManagerSend the a vertex's data to other fragment through incoming and outgoing edges.- Specified by:
sendMsgThroughEdgesArrowProjectedin interfaceDefaultMessageManager- Type Parameters:
FRAG_T- fragment type.MSG_T- message type.- Parameters:
frag- ArrowProjectedFragment.vertex- querying vertex.msg- msg to send.
-
-