Package com.alibaba.graphscope.parallel

Interface ParallelPropertyMessageManager

All Superinterfaces:

com.alibaba.fastffi.FFIPointer, FFIType, MessageManagerBase, Serializable

public interface ParallelPropertyMessageManager
extends MessageManagerBase

As PropertyParallelMessager.h has not much difference from ParallelMessageManager.

Method Summary

Modifier and Type	Method	Description
@com.alibaba.fastffi.FFINameAlias("GetMessages") boolean	getMessageInBuffer(MessageInBuffer buf)
void	initChannels(int channel_num)
default <OID_T,VID_T,MSG_T> void	parallelProcess(ArrowFragment<OID_T> frag, int threadNum, ExecutorService executor, Supplier<MSG_T> msgSupplier, BiConsumer<Vertex<Long>,MSG_T> consumer)	This define the parallel process for default labelid, i.e.
default <FRAG_T extends IFragment,MSG_T,UNUSED_T> void	parallelProcess(FRAG_T frag, int vertexLabelId, int threadNum, ExecutorService executor, Supplier<MSG_T> msgSupplier, TriConsumer<Vertex<Long>,MSG_T,Integer> consumer)
<FRAG_T extends ArrowFragment,MSG_T> void	SendMsgThroughEdges(FRAG_T frag, Vertex<Long> vertex, int elabelId, MSG_T msg, int channel_id)
<FRAG_T extends ArrowFragment,MSG_T> void	sendMsgThroughIEdges(FRAG_T frag, Vertex<Long> vertex, int elabelId, MSG_T msg, int channel_id)
<FRAG_T extends ArrowFragment,MSG_T> void	sendMsgThroughOEdges(FRAG_T frag, Vertex<Long> vertex, int elabelId, MSG_T msg, int channel_id)
<FRAG_T extends ArrowFragment,MSG_T> void	syncStateOnOuterVertex(FRAG_T frag, Vertex<Long> vertex, MSG_T msg, int channel_id)
<FRAG_T extends ArrowFragment,OID> void	syncStateOnOuterVertexNoMsg(FRAG_T frag, Vertex<Long> vertex, int channel_id, OID unused)	SyncState on outer vertex without message, used in bfs etc.

Methods inherited from interface com.alibaba.fastffi.FFIPointer

getAddress

Methods inherited from interface com.alibaba.graphscope.parallel.MessageManagerBase

finishARound, forceContinue, getMsgSize, start, startARound, toTerminate

Method Detail

initChannels

void initChannels(int channel_num)

syncStateOnOuterVertex

<FRAG_T extends ArrowFragment,MSG_T> void syncStateOnOuterVertex(FRAG_T frag,
                                                                       Vertex<Long> vertex,
                                                                       MSG_T msg,
                                                                       int channel_id)

syncStateOnOuterVertexNoMsg

<FRAG_T extends ArrowFragment,OID> void syncStateOnOuterVertexNoMsg(FRAG_T frag,
                                                                          Vertex<Long> vertex,
                                                                          int channel_id,
                                                                          OID unused)

SyncState on outer vertex without message, used in bfs etc.

Type Parameters:

FRAG_T - fragment type.

Parameters:

frag - fragment.

vertex - query vertex.

channel_id - message channel id.

sendMsgThroughOEdges

<FRAG_T extends ArrowFragment,MSG_T> void sendMsgThroughOEdges(FRAG_T frag,
                                                                     Vertex<Long> vertex,
                                                                     int elabelId,
                                                                     MSG_T msg,
                                                                     int channel_id)

sendMsgThroughIEdges

<FRAG_T extends ArrowFragment,MSG_T> void sendMsgThroughIEdges(FRAG_T frag,
                                                                     Vertex<Long> vertex,
                                                                     int elabelId,
                                                                     MSG_T msg,
                                                                     int channel_id)

SendMsgThroughEdges

<FRAG_T extends ArrowFragment,MSG_T> void SendMsgThroughEdges(FRAG_T frag,
                                                                    Vertex<Long> vertex,
                                                                    int elabelId,
                                                                    MSG_T msg,
                                                                    int channel_id)

getMessageInBuffer

@com.alibaba.fastffi.FFINameAlias("GetMessages") boolean getMessageInBuffer(MessageInBuffer buf)

parallelProcess

default <FRAG_T extends IFragment,MSG_T,UNUSED_T> void parallelProcess(FRAG_T frag,
                                                                                   int vertexLabelId,
                                                                                   int threadNum,
                                                                                   ExecutorService executor,
                                                                                   Supplier<MSG_T> msgSupplier,
                                                                                   TriConsumer<Vertex<Long>,MSG_T,Integer> consumer)

parallelProcess

default <OID_T,VID_T,MSG_T> void parallelProcess(ArrowFragment<OID_T> frag,
                                                             int threadNum,
                                                             ExecutorService executor,
                                                             Supplier<MSG_T> msgSupplier,
                                                             BiConsumer<Vertex<Long>,MSG_T> consumer)

This define the parallel process for default labelid, i.e. 0.

Type Parameters:

MSG_T - message type.

Parameters:

frag - fragment.

threadNum - num thread.

executor - Executor service.

msgSupplier - lambda for msg creation.

consumer - consumer.