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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description longdigest(IFragment<Long,Long,?,?> fragment, MessageInBuffer messageInBuffer, ThreadSafeBitSet curSet, int threadId)to digest message send along edges, which should be resolved via GetMessages.voiddigest(IFragment<Long,Long,?,?> fragment, FFIByteVector vector, ThreadSafeBitSet curSet, int threadId)voidflushMessages(ThreadSafeBitSet nextSet, ParallelMessageManager messageManager, IFragment<Long,Long,?,?> fragment, int[] fid2WorkerId, ExecutorService executorService)Tget(int index)voidset(int index, T value)intsize()-
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:
flushMessagesin interfaceMessageStore<T>- Overrides:
flushMessagesin classAbstractMessageStore<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:MessageStoreto digest message send along edges, which should be resolved via GetMessages.
-
-