Package com.alibaba.graphscope.parallel.cache

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 Summary

Fields

Modifier and Type	Field	Description
static org.slf4j.Logger	logger

Method Summary

Modifier and Type	Method	Description
void	clear()
void	flushMessage()	FLush all cached messages out.
static <I_ extends org.apache.hadoop.io.WritableComparable,M_ extends org.apache.hadoop.io.Writable,GS_VID_T_> SendMessageCache<I_,M_,GS_VID_T_>	newMessageCache(int fragNum, int fragId, NettyClient client, ImmutableClassesGiraphConfiguration<I_,?,M_> conf)
void	removeMessageToSelf(MessageStore<I,M,GS_VID_T> nextIncomingMessages)
void	sendMessage(int dstFragId, GS_VID_T gid, M message)

Field Detail

logger

static final org.slf4j.Logger logger

Method Detail

newMessageCache

static <I_ extends org.apache.hadoop.io.WritableComparable,M_ extends org.apache.hadoop.io.Writable,GS_VID_T_> SendMessageCache<I_,M_,GS_VID_T_> newMessageCache(int fragNum,
                                                                                                                                                                                         int fragId,
                                                                                                                                                                                         NettyClient client,
                                                                                                                                                                                         ImmutableClassesGiraphConfiguration<I_,?,M_> conf)

sendMessage

void sendMessage(int dstFragId,
                 GS_VID_T gid,
                 M message)

removeMessageToSelf

void removeMessageToSelf(MessageStore<I,M,GS_VID_T> nextIncomingMessages)

flushMessage

void flushMessage()

FLush all cached messages out.

clear

void clear()