Interface SendMessageCache<I extends org.apache.hadoop.io.WritableComparable,​M extends org.apache.hadoop.io.Writable,​GS_VID_T>

  • All Known Implementing Classes:
    BatchWritableMessageCache, ByteBufMessageCache

    public interface SendMessageCache<I extends org.apache.hadoop.io.WritableComparable,​M extends org.apache.hadoop.io.Writable,​GS_VID_T>
    Message cache is a special case of SendDataCache, in which the stored data is a pair (I,D),I is the vertex OID, D is the message for Vertex.
    • Field Detail

      • logger

        static final org.slf4j.Logger logger
    • Method Detail

      • sendMessage

        void sendMessage​(int dstFragId,
                         GS_VID_T gid,
                         M message)
      • flushMessage

        void flushMessage()
        FLush all cached messages out.
      • clear

        void clear()