Package com.alibaba.graphscope.utils

Class ObjectMessageStore<T>

java.lang.Object

com.alibaba.graphscope.utils.AbstractMessageStore<T>

com.alibaba.graphscope.utils.ObjectMessageStore<T>

All Implemented Interfaces:

PrimitiveArray<T>, MessageStore<T>, Serializable

public class ObjectMessageStore<T>
extends AbstractMessageStore<T>

See Also:

Serialized Form

Field Summary

Fields inherited from class com.alibaba.graphscope.utils.AbstractMessageStore

conf, idParser, ivnum, nextSet, outputStream, tmpVertex

Constructor Summary

Constructors

Constructor	Description
ObjectMessageStore(int len, int fnum, int numCores, int ivnum, Class<? extends T> clz, scala.Function2<T,T,T> function2, ThreadSafeBitSet nextSet, GraphXConf<?,?,?> conf)

Method Summary

Modifier and Type	Method	Description
long	digest(IFragment<Long,Long,?,?> fragment, MessageInBuffer messageInBuffer, ThreadSafeBitSet curSet, int threadId)	to digest message send along edges, which should be resolved via GetMessages.
void	digest(IFragment<Long,Long,?,?> fragment, FFIByteVector vector, ThreadSafeBitSet curSet, int threadId)
void	flushMessages(ThreadSafeBitSet nextSet, ParallelMessageManager messageManager, IFragment<Long,Long,?,?> fragment, int[] fid2WorkerId, ExecutorService executorService)
T	get(int index)
void	set(int index, T value)
int	size()

Methods inherited from class com.alibaba.graphscope.utils.AbstractMessageStore

addMessages, sendMsgThroughIEdges

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.alibaba.graphscope.utils.array.PrimitiveArray

get, set

Constructor Detail

ObjectMessageStore

public ObjectMessageStore(int len,
                          int fnum,
                          int numCores,
                          int ivnum,
                          Class<? extends T> clz,
                          scala.Function2<T,T,T> function2,
                          ThreadSafeBitSet nextSet,
                          GraphXConf<?,?,?> conf)

Method Detail

get

public T get(int index)

set

public void set(int index,
                T value)

size

public int size()

flushMessages

public void flushMessages(ThreadSafeBitSet nextSet,
                          ParallelMessageManager messageManager,
                          IFragment<Long,Long,?,?> fragment,
                          int[] fid2WorkerId,
                          ExecutorService executorService)
                   throws IOException

Specified by:

flushMessages in interface MessageStore<T>

Overrides:

flushMessages in class AbstractMessageStore<T>

Throws:

IOException

digest

public void digest(IFragment<Long,Long,?,?> fragment,
                   FFIByteVector vector,
                   ThreadSafeBitSet curSet,
                   int threadId)

digest

public long digest(IFragment<Long,Long,?,?> fragment,
                   MessageInBuffer messageInBuffer,
                   ThreadSafeBitSet curSet,
                   int threadId)

Description copied from interface: MessageStore

to digest message send along edges, which should be resolved via GetMessages.