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

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)
Integer	get(int index)
void	set(int index, Integer 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

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: MessageStore

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