java.lang.Object
- com.alibaba.graphscope.parallel.message.DefaultMessageStore<OID_T,MSG_T,GS_VID_T>

All Implemented Interfaces:: MessageStore<OID_T,MSG_T,GS_VID_T>

public class DefaultMessageStore<OID_T extends org.apache.hadoop.io.WritableComparable,MSG_T extends org.apache.hadoop.io.Writable,GS_VID_T>
extends Object
implements MessageStore<OID_T,MSG_T,GS_VID_T>

Constructor Summary

Constructors
Constructor Description

DefaultMessageStore(IFragment<?,GS_VID_T,?,?> fragment, ImmutableClassesGiraphConfiguration<OID_T,?,?> conf)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`addGidMessage(GS_VID_T gid, MSG_T writable)`	For messages bound with gid, first get lid.
`void`	`addGidMessages(Iterator<GS_VID_T> gids, Iterator<MSG_T> writables)`
`void`	`addLidMessage(GS_VID_T lid, MSG_T 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<MSG_T>`	`getMessages(GS_VID_T lid)`
`Iterable<MSG_T>`	`getMessages(Long lid)`
`boolean`	`messageAvailable(GS_VID_T lid)`	Check for lid, any messages available.
`boolean`	`messageAvailable(Long lid)`
`void`	`swap(MessageStore<OID_T,MSG_T,GS_VID_T> other)`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - DefaultMessageStore
```
public DefaultMessageStore(IFragment<?,GS_VID_T,?,?> fragment,
                           ImmutableClassesGiraphConfiguration<OID_T,?,?> conf)
```
- Method Detail
  - addLidMessage
```
public void addLidMessage(GS_VID_T lid,
                          MSG_T writable)
```
    Specified by:
    
    addLidMessage in interface MessageStore<OID_T extends org.apache.hadoop.io.WritableComparable,MSG_T extends org.apache.hadoop.io.Writable,GS_VID_T>
  - addGidMessages
```
public void addGidMessages(Iterator<GS_VID_T> gids,
                           Iterator<MSG_T> writables)
```
    Specified by:
    
    addGidMessages in interface MessageStore<OID_T extends org.apache.hadoop.io.WritableComparable,MSG_T extends org.apache.hadoop.io.Writable,GS_VID_T>
  - addGidMessage
```
public void addGidMessage(GS_VID_T gid,
                          MSG_T writable)
```
    For messages bound with gid, first get lid.
    
    Specified by:
    
    addGidMessage in interface MessageStore<OID_T extends org.apache.hadoop.io.WritableComparable,MSG_T extends org.apache.hadoop.io.Writable,GS_VID_T>
    
    Parameters:
    
    gid - global id
    
    writable - msg
  - swap
```
public void swap(MessageStore<OID_T,MSG_T,GS_VID_T> other)
```
    Specified by:
    
    swap in interface MessageStore<OID_T extends org.apache.hadoop.io.WritableComparable,MSG_T extends org.apache.hadoop.io.Writable,GS_VID_T>
  - clearAll
```
public void clearAll()
```
    Specified by:
    
    clearAll in interface MessageStore<OID_T extends org.apache.hadoop.io.WritableComparable,MSG_T extends org.apache.hadoop.io.Writable,GS_VID_T>
  - anyMessageReceived
```
public boolean anyMessageReceived()
```
    Check whether any messages received.
    
    Specified by:
    
    anyMessageReceived in interface MessageStore<OID_T extends org.apache.hadoop.io.WritableComparable,MSG_T extends org.apache.hadoop.io.Writable,GS_VID_T>
  - messageAvailable
```
public boolean messageAvailable(GS_VID_T lid)
```
    Check for lid, any messages available.
    
    Specified by:
    
    messageAvailable in interface MessageStore<OID_T extends org.apache.hadoop.io.WritableComparable,MSG_T extends org.apache.hadoop.io.Writable,GS_VID_T>
    
    Parameters:
    
    lid - lid.
    
    Returns:
    
    true if has message
  - messageAvailable
```
public boolean messageAvailable(Long lid)
```
    Specified by:
    
    messageAvailable in interface MessageStore<OID_T extends org.apache.hadoop.io.WritableComparable,MSG_T extends org.apache.hadoop.io.Writable,GS_VID_T>
  - getMessages
```
public Iterable<MSG_T> getMessages(Long lid)
```
    Specified by:
    
    getMessages in interface MessageStore<OID_T extends org.apache.hadoop.io.WritableComparable,MSG_T extends org.apache.hadoop.io.Writable,GS_VID_T>
  - getMessages
```
public Iterable<MSG_T> getMessages(GS_VID_T lid)
```
    Specified by:
    
    getMessages in interface MessageStore<OID_T extends org.apache.hadoop.io.WritableComparable,MSG_T extends org.apache.hadoop.io.Writable,GS_VID_T>
  - digest
```
public void digest(FFIByteVector vector)
```
    For a bytestream provided by FFIByteVector, read from it and digest its content.
    
    Specified by:
    
    digest in interface MessageStore<OID_T extends org.apache.hadoop.io.WritableComparable,MSG_T extends org.apache.hadoop.io.Writable,GS_VID_T>
    
    Parameters:
    
    vector -
  - digestByteBuffer
```
public void digestByteBuffer(io.netty.buffer.ByteBuf buf,
                             boolean fromSelf)
```
    Specified by:
    
    digestByteBuffer in interface MessageStore<OID_T extends org.apache.hadoop.io.WritableComparable,MSG_T extends org.apache.hadoop.io.Writable,GS_VID_T>

Class DefaultMessageStore<OID_T extends org.apache.hadoop.io.WritableComparable,​MSG_T extends org.apache.hadoop.io.Writable,​GS_VID_T>

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

DefaultMessageStore

Method Detail

addLidMessage

addGidMessages

addGidMessage

swap

clearAll

anyMessageReceived

messageAvailable

messageAvailable

getMessages

getMessages

digest

digestByteBuffer

Class DefaultMessageStore<OID_T extends org.apache.hadoop.io.WritableComparable,MSG_T extends org.apache.hadoop.io.Writable,GS_VID_T>