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

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

public class BatchWritableMessageCache<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>

Constructor Summary

Constructors
Constructor Description

BatchWritableMessageCache(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
  - BatchWritableMessageCache
```
public BatchWritableMessageCache(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. after flush, clear should be called.
    
    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 BatchWritableMessageCache<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

BatchWritableMessageCache

Method Detail

sendMessage

removeMessageToSelf

flushMessage

clear

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