Uses of Interface
com.alibaba.graphscope.parallel.message.MessageStore

Packages that use MessageStore

Package	Description
com.alibaba.graphscope.parallel.cache
com.alibaba.graphscope.parallel.cache.impl
com.alibaba.graphscope.parallel.message
com.alibaba.graphscope.parallel.mm.impl
com.alibaba.graphscope.parallel.netty
com.alibaba.graphscope.parallel.netty.handler
com.alibaba.graphscope.parallel.netty.request
com.alibaba.graphscope.parallel.netty.request.impl

Uses of MessageStore in com.alibaba.graphscope.parallel.cache

Methods in com.alibaba.graphscope.parallel.cache with parameters of type MessageStore

Modifier and Type	Method	Description
void	SendMessageCache.removeMessageToSelf(MessageStore<I,M,GS_VID_T> nextIncomingMessages)

Uses of MessageStore in com.alibaba.graphscope.parallel.cache.impl

Methods in com.alibaba.graphscope.parallel.cache.impl with parameters of type MessageStore

Modifier and Type	Method	Description
void	BatchWritableMessageCache.removeMessageToSelf(MessageStore<I,M,GS_VID_T> nextIncomingMessages)
void	ByteBufMessageCache.removeMessageToSelf(MessageStore<I,M,GS_VID_T> nextIncomingMessages)

Uses of MessageStore in com.alibaba.graphscope.parallel.message

Classes in com.alibaba.graphscope.parallel.message that implement MessageStore

Modifier and Type	Class	Description
class	DefaultMessageStore<OID_T extends org.apache.hadoop.io.WritableComparable,MSG_T extends org.apache.hadoop.io.Writable,GS_VID_T>

Methods in com.alibaba.graphscope.parallel.message that return MessageStore

Modifier and Type	Method	Description
MessageStore<I,M,GS_VID_T>	DefaultMessageStoreFactory.newStore(org.apache.giraph.conf.MessageClasses<I,M> messageClasses)	Creates new message store.

Methods in com.alibaba.graphscope.parallel.message with parameters of type MessageStore

Modifier and Type	Method	Description
void	DefaultMessageStore.swap(MessageStore<OID_T,MSG_T,GS_VID_T> other)
void	MessageStore.swap(MessageStore<I,M,GS_VID_T> other)

Uses of MessageStore in com.alibaba.graphscope.parallel.mm.impl

Fields in com.alibaba.graphscope.parallel.mm.impl declared as MessageStore

Modifier and Type	Field	Description
protected MessageStore<OID_T,IN_MSG_T,GS_VID_T>	AbstractMessageManager.currentIncomingMessageStore
protected MessageStore<OID_T,IN_MSG_T,GS_VID_T>	AbstractMessageManager.nextIncomingMessageStore

Uses of MessageStore in com.alibaba.graphscope.parallel.netty

Methods in com.alibaba.graphscope.parallel.netty with parameters of type MessageStore

Modifier and Type	Method	Description
void	NettyServer.preSuperStep(MessageStore<OID_T,org.apache.hadoop.io.Writable,GS_VID_T> nextIncomingMessages)

Constructors in com.alibaba.graphscope.parallel.netty with parameters of type MessageStore

Constructor	Description
NettyServer(ImmutableClassesGiraphConfiguration conf, IFragment fragment, NetworkMap networkMap, MessageStore<OID_T,org.apache.hadoop.io.Writable,GS_VID_T> nextIncomingMessages, Thread.UncaughtExceptionHandler exceptionHandler)

Uses of MessageStore in com.alibaba.graphscope.parallel.netty.handler

Methods in com.alibaba.graphscope.parallel.netty.handler with parameters of type MessageStore

Modifier and Type	Method	Description
void	NettyServerHandler.preSuperStep(MessageStore<OID_T,org.apache.hadoop.io.Writable,GS_VID_T> nextIncomingMessages)

Constructors in com.alibaba.graphscope.parallel.netty.handler with parameters of type MessageStore

Constructor	Description
NettyServerHandler(IFragment<?,GS_VID_T,?,?> fragment, MessageStore<OID_T,org.apache.hadoop.io.Writable,GS_VID_T> nextIncomingMessages)

Uses of MessageStore in com.alibaba.graphscope.parallel.netty.request

Methods in com.alibaba.graphscope.parallel.netty.request with parameters of type MessageStore

Modifier and Type	Method	Description
abstract void	WritableRequest.doRequest(MessageStore<I,org.apache.hadoop.io.Writable,?> messageStore)	Apply this request on this message storage.

Uses of MessageStore in com.alibaba.graphscope.parallel.netty.request.impl

Methods in com.alibaba.graphscope.parallel.netty.request.impl with parameters of type MessageStore

Modifier and Type	Method	Description
void	BatchWritableRequest.doRequest(MessageStore messageStore)	Apply this request on this message storage.
void	ByteBufRequest.doRequest(MessageStore messageStore)	Apply this request on this message storage.
void	GidLongWritableRequest.doRequest(MessageStore messageStore)	Apply this request on this message storage.
void	OneLongWritableRequest.doRequest(MessageStore messageStore)	Apply this request on this message storage.