Interface DefaultMessageManagerGen

    • 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 interface DefaultMessageManager
        Type Parameters:
        MSG_T - msg type
        msg - 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 interface DefaultMessageManager
        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 interface DefaultMessageManager
        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 interface DefaultMessageManager
        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 interface DefaultMessageManager
        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 interface DefaultMessageManager
        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 interface DefaultMessageManager
        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 interface DefaultMessageManager
        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 interface DefaultMessageManager
        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 interface DefaultMessageManager
        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 interface DefaultMessageManager
        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 interface DefaultMessageManager
        Type Parameters:
        FRAG_T - fragment type.
        MSG_T - message type.
        Parameters:
        frag - ArrowProjectedFragment.
        vertex - querying vertex.
        msg - msg to send.