java.lang.Object
- com.alibaba.graphscope.parallel.cache.impl.ByteBufMessageCache<I,M,GS_VID_T>

Type Parameters:: I - vertex id type; M - message type; GS_VID_T - gs vid

All Implemented Interfaces:: SendMessageCache<I,M,GS_VID_T>

public class ByteBufMessageCache<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable,GS_VID_T>
extends Object
implements SendMessageCache<I,M,GS_VID_T>

Use a byteBuf as underlying cache storage.

Constructor Summary

Constructors
Constructor	Description
`ByteBufMessageCache(int fragNum, int fragId, NettyClient client, ImmutableClassesGiraphConfiguration<I,?,?> conf)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`clear()`
`void`	`flushMessage()`	FLush all cached messages out.
`void`	`removeMessageToSelf(MessageStore<I,M,GS_VID_T> nextIncomingMessages)`
`void`	`sendMessage(int dstFragId, GS_VID_T gid, M message)`

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

- Constructor Detail
  - ByteBufMessageCache
```
public ByteBufMessageCache(int fragNum,
                           int fragId,
                           NettyClient client,
                           ImmutableClassesGiraphConfiguration<I,?,?> conf)
```
- Method Detail
  - sendMessage
```
public void sendMessage(int dstFragId,
                        GS_VID_T gid,
                        M message)
```
    Specified by:
    
    sendMessage in interface SendMessageCache<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable,GS_VID_T>
  - removeMessageToSelf
```
public void removeMessageToSelf(MessageStore<I,M,GS_VID_T> nextIncomingMessages)
```
    Specified by:
    
    removeMessageToSelf in interface SendMessageCache<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable,GS_VID_T>
  - flushMessage
```
public void flushMessage()
```
    FLush all cached messages out.
    
    Specified by:
    
    flushMessage in interface SendMessageCache<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable,GS_VID_T>
  - clear
```
public void clear()
```
    Specified by:
    
    clear in interface SendMessageCache<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable,GS_VID_T>

Class ByteBufMessageCache<I extends org.apache.hadoop.io.WritableComparable,​M extends org.apache.hadoop.io.Writable,​GS_VID_T>

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

ByteBufMessageCache

Method Detail

sendMessage

removeMessageToSelf

flushMessage

clear

Class ByteBufMessageCache<I extends org.apache.hadoop.io.WritableComparable,M extends org.apache.hadoop.io.Writable,GS_VID_T>