Package com.alibaba.graphscope.utils

Class LongMessageStore

java.lang.Object

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

com.alibaba.graphscope.utils.LongMessageStore

All Implemented Interfaces:

PrimitiveArray<Long>, MessageStore<Long>, Serializable

public class LongMessageStore
extends AbstractMessageStore<Long>

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
LongMessageStore(int len, int fnum, int numCores, int ivnum, scala.Function2<Long,Long,Long> mergeMessage, 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)
Long	get(int index)
void	set(int index, Long value)
int	size()

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

Constructor Detail

LongMessageStore

public LongMessageStore(int len,
                        int fnum,
                        int numCores,
                        int ivnum,
                        scala.Function2<Long,Long,Long> mergeMessage,
                        ThreadSafeBitSet nextSet,
                        GraphXConf<?,?,?> conf)

Method Detail

get

public Long get(int index)

set

public void set(int index,
                Long 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: MessageStore

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