Package com.alibaba.graphscope.utils
Class IntMessageStore
- java.lang.Object
-
- com.alibaba.graphscope.utils.AbstractMessageStore<Integer>
-
- com.alibaba.graphscope.utils.IntMessageStore
-
- All Implemented Interfaces:
PrimitiveArray<Integer>,MessageStore<Integer>,Serializable
public class IntMessageStore extends AbstractMessageStore<Integer>
- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description protected IntMsg[]msgWrappers-
Fields inherited from class com.alibaba.graphscope.utils.AbstractMessageStore
conf, idParser, ivnum, nextSet, outputStream, tmpVertex
-
-
Constructor Summary
Constructors Constructor Description IntMessageStore(int len, int fnum, int numCores, int ivnum, scala.Function2<Integer,Integer,Integer> 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)Integerget(int index)voidset(int index, Integer value)intsize()-
Methods inherited from class com.alibaba.graphscope.utils.AbstractMessageStore
addMessages, flushMessages, 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
-
-
-
-
Field Detail
-
msgWrappers
protected IntMsg[] msgWrappers
-
-
Constructor Detail
-
IntMessageStore
public IntMessageStore(int len, int fnum, int numCores, int ivnum, scala.Function2<Integer,Integer,Integer> function2, ThreadSafeBitSet nextSet, GraphXConf<?,?,?> conf)
-
-
Method Detail
-
get
public Integer get(int index)
-
set
public void set(int index, Integer value)
-
size
public int size()
-
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.
-
-