java.lang.Object
- com.alibaba.graphscope.utils.AbstractMessageStore<T>

All Implemented Interfaces:

PrimitiveArray<T>, MessageStore<T>, Serializable

Direct Known Subclasses:

DoubleMessageStore, IntMessageStore, LongMessageStore, ObjectMessageStore
```
public abstract class AbstractMessageStore<T>
extends Object
implements MessageStore<T>
```
See Also:

Serialized Form

Field Summary

Fields
Modifier and Type	Field	Description
`protected GraphXConf<?,?,?>`	`conf`
`protected com.alibaba.graphscope.graphx.utils.IdParser`	`idParser`
`protected int`	`ivnum`
`protected ThreadSafeBitSet`	`nextSet`
`protected FFIByteVectorOutputStream[]`	`outputStream`
`protected Vertex<Long>[]`	`tmpVertex`

Constructor Summary

Constructors
Constructor Description

AbstractMessageStore(int fnum, int numCores, ThreadSafeBitSet nextSet, GraphXConf<?,?,?> conf, int ivnum)

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`addMessages(scala.collection.Iterator<scala.Tuple2<Long,T>> msgs, int threadId, com.alibaba.graphscope.graphx.graph.GSEdgeTripletImpl edgeTriplet, IFragment<Long,Long,?,?> fragment, int srcLid, int dstLid)`
`void`	`flushMessages(ThreadSafeBitSet nextSet, ParallelMessageManager messageManager, IFragment<Long,Long,?,?> fragment, int[] fid2WorkerId, ExecutorService executorService)`
`<MSG_T> void`	`sendMsgThroughIEdges(Vertex<Long> vertex, MSG_T msg, int threadId, ParallelMessageManager messageManager, IFragment<Long,Long,?,?> fragment)`	we assume this function is thread safe

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.MessageStore
digest, digest

Methods inherited from interface com.alibaba.graphscope.utils.array.PrimitiveArray
get, get, set, set, size

Field Detail

tmpVertex
```
protected Vertex<Long>[] tmpVertex
```

nextSet
```
protected ThreadSafeBitSet nextSet
```

idParser

protected com.alibaba.graphscope.graphx.utils.IdParser idParser

outputStream

protected FFIByteVectorOutputStream[] outputStream

conf
```
protected GraphXConf<?,?,?> conf
```

ivnum
```
protected int ivnum
```

Constructor Detail

AbstractMessageStore

public AbstractMessageStore(int fnum,
                            int numCores,
                            ThreadSafeBitSet nextSet,
                            GraphXConf<?,?,?> conf,
                            int ivnum)

Method Detail

sendMsgThroughIEdges

public <MSG_T> void sendMsgThroughIEdges(Vertex<Long> vertex,
                                         MSG_T msg,
                                         int threadId,
                                         ParallelMessageManager messageManager,
                                         IFragment<Long,Long,?,?> fragment)

we assume this function is thread safe

Specified by:: sendMsgThroughIEdges in interface MessageStore<T>

addMessages

public void addMessages(scala.collection.Iterator<scala.Tuple2<Long,T>> msgs,
                        int threadId,
                        com.alibaba.graphscope.graphx.graph.GSEdgeTripletImpl edgeTriplet,
                        IFragment<Long,Long,?,?> fragment,
                        int srcLid,
                        int dstLid)
                 throws InterruptedException

Specified by:: addMessages in interface MessageStore<T>
Throws:: InterruptedException

flushMessages

public void flushMessages(ThreadSafeBitSet nextSet,
                          ParallelMessageManager messageManager,
                          IFragment<Long,Long,?,?> fragment,
                          int[] fid2WorkerId,
                          ExecutorService executorService)
                   throws IOException

Specified by:: flushMessages in interface MessageStore<T>
Throws:: IOException

Class AbstractMessageStore<T>

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Methods inherited from interface com.alibaba.graphscope.utils.MessageStore

Methods inherited from interface com.alibaba.graphscope.utils.array.PrimitiveArray

Field Detail

tmpVertex

nextSet

idParser

outputStream

conf

ivnum

Constructor Detail

AbstractMessageStore

Method Detail

sendMsgThroughIEdges

addMessages

flushMessages