Package com.alibaba.graphscope.communication

Interface FFICommunicator

All Superinterfaces:

com.alibaba.fastffi.FFIPointer, FFIType, Serializable

All Known Subinterfaces:

FFICommunicatorGen

All Known Implementing Classes:

FFICommunicatorGen_cxx_0xd6e741c0

public interface FFICommunicator
extends com.alibaba.fastffi.FFIPointer

The java wrapper for grape Communicator class, which provides some useful aggregators. Shall not be used by user.

For User-defined msg types, the corresponding code is generated by graphscope-processor.

Method Summary

Modifier and Type	Method	Description
<MSG_T> void	max(MSG_T msgIn, MSG_T msgOut)
<MSG_T> void	min(MSG_T msgIn, MSG_T msgOut)
<MSG_T> void	receiveFrom(int srcFid, MSG_T msgIn)
<MST_T> void	sendTo(int dstFid, MST_T msgOut)
<MSG_T> void	sum(MSG_T msgIn, MSG_T msgOut)

Methods inherited from interface com.alibaba.fastffi.FFIPointer

getAddress

Method Detail

sum

<MSG_T> void sum(MSG_T msgIn,
                 MSG_T msgOut)

min

<MSG_T> void min(MSG_T msgIn,
                 MSG_T msgOut)

max

<MSG_T> void max(MSG_T msgIn,
                 MSG_T msgOut)

sendTo

<MST_T> void sendTo(int dstFid,
                    MST_T msgOut)

receiveFrom

<MSG_T> void receiveFrom(int srcFid,
                         MSG_T msgIn)