Package com.alibaba.graphscope.utils

Class DoubleMessageStore

java.lang.Object

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

com.alibaba.graphscope.utils.DoubleMessageStore

All Implemented Interfaces:

PrimitiveArray<Double>, MessageStore<Double>, Serializable

public class DoubleMessageStore
extends AbstractMessageStore<Double>

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected DoubleMsg[]	msgWrappers

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

conf, idParser, ivnum, nextSet, outputStream, tmpVertex

Constructor Summary

Constructors

Constructor	Description
DoubleMessageStore(int len, int fnum, int numCores, int ivnum, scala.Function2<Double,Double,Double> 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)
Double	get(int index)
void	set(int index, Double 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 DoubleMsg[] msgWrappers

Constructor Detail

DoubleMessageStore

public DoubleMessageStore(int len,
                          int fnum,
                          int numCores,
                          int ivnum,
                          scala.Function2<Double,Double,Double> function2,
                          ThreadSafeBitSet nextSet,
                          GraphXConf<?,?,?> conf)

Method Detail

get

public Double get(int index)

set

public void set(int index,
                Double 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.