public interface MessageStore<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable,GS_VID_T>

Message store

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	Description
`void`	`addGidMessage(GS_VID_T gid, M writable)`	For messages bound with gid, first get lid.
`void`	`addGidMessages(Iterator<GS_VID_T> gids, Iterator<M> writables)`
`void`	`addLidMessage(GS_VID_T lid, M writable)`
`boolean`	`anyMessageReceived()`	Check whether any messages received.
`void`	`clearAll()`
`void`	`digest(FFIByteVector vector)`	For a bytestream provided by FFIByteVector, read from it and digest its content.
`void`	`digestByteBuffer(io.netty.buffer.ByteBuf buf, boolean fromSelf)`
`Iterable<M>`	`getMessages(GS_VID_T lid)`
`Iterable<M>`	`getMessages(Long lid)`
`boolean`	`messageAvailable(GS_VID_T lid)`	Check for lid, any messages available.
`boolean`	`messageAvailable(Long lid)`
`void`	`swap(MessageStore<I,M,GS_VID_T> other)`

void addLidMessage(GS_VID_T lid,
                   M writable)

void addGidMessages(Iterator<GS_VID_T> gids,
                    Iterator<M> writables)

void swap(MessageStore<I,M,GS_VID_T> other)

anyMessageReceived
```
boolean anyMessageReceived()
```
Check whether any messages received.

Iterable<M> getMessages(GS_VID_T lid)

void digestByteBuffer(io.netty.buffer.ByteBuf buf,
                      boolean fromSelf)

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

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