Package com.alibaba.graphscope.parallel

Interface MessageInBuffer

All Superinterfaces:

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

All Known Subinterfaces:

MessageInBufferGen

All Known Implementing Classes:

MessageInBufferGen_cxx_0x2b9fb1a1

public interface MessageInBuffer
extends com.alibaba.fastffi.CXXPointer

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	MessageInBuffer.Factory

Method Summary

Modifier and Type	Method	Description
default <OID_T,VID_T,VDATA_T,EDATA_T,MSG_T,UNUSED_T> boolean	getMessage(IFragment<OID_T,VID_T,VDATA_T,EDATA_T> frag, Vertex<VID_T> vertex, MSG_T msg)
<FRAG_T extends ArrowFragment,MSG_T,UNUSED> @com.alibaba.fastffi.FFINameAlias("GetMessage") boolean	getMessage(FRAG_T frag, Vertex<Long> vertex, MSG_T msg, UNUSED unused)
<OID_T,VID_T,VDATA_T,EDATA_T,FRAG_T extends ArrowProjectedFragment<OID_T,VID_T,VDATA_T,EDATA_T>,MSG_T,UNUSED_T> @com.alibaba.fastffi.FFINameAlias("GetMessage") boolean	getMessageArrowProjected(FRAG_T frag, Vertex<VID_T> vertex, MSG_T msg, UNUSED_T unused)
<OID_T,VID_T,VDATA_T,EDATA_T,MSG_T,UNUSED_T> @com.alibaba.fastffi.FFINameAlias("GetMessage") boolean	getMessageImmutable(ImmutableEdgecutFragment<OID_T,VID_T,VDATA_T,EDATA_T> frag, Vertex<VID_T> vertex, MSG_T msg, UNUSED_T unused)
<MSG_T> @com.alibaba.fastffi.FFINameAlias("GetMessage") boolean	getPureMessage(MSG_T msg)	Get message into target MSG_T.

Methods inherited from interface com.alibaba.fastffi.CXXPointer

delete

Methods inherited from interface com.alibaba.fastffi.FFIPointer

getAddress

Method Detail

getMessage

default <OID_T,VID_T,VDATA_T,EDATA_T,MSG_T,UNUSED_T> boolean getMessage(IFragment<OID_T,VID_T,VDATA_T,EDATA_T> frag,
                                                                                                      Vertex<VID_T> vertex,
                                                                                                      MSG_T msg)

getMessage

<FRAG_T extends ArrowFragment,MSG_T,UNUSED> @com.alibaba.fastffi.FFINameAlias("GetMessage") boolean getMessage(FRAG_T frag,
                                                                                                                           Vertex<Long> vertex,
                                                                                                                           MSG_T msg,
                                                                                                                           UNUSED unused)

getMessageArrowProjected

<OID_T,VID_T,VDATA_T,EDATA_T,FRAG_T extends ArrowProjectedFragment<OID_T,VID_T,VDATA_T,EDATA_T>,MSG_T,UNUSED_T> @com.alibaba.fastffi.FFINameAlias("GetMessage") boolean getMessageArrowProjected(FRAG_T frag,
                                                                                                                                                                                                                                                       Vertex<VID_T> vertex,
                                                                                                                                                                                                                                                       MSG_T msg,
                                                                                                                                                                                                                                                       UNUSED_T unused)

getMessageImmutable

<OID_T,VID_T,VDATA_T,EDATA_T,MSG_T,UNUSED_T> @com.alibaba.fastffi.FFINameAlias("GetMessage") boolean getMessageImmutable(ImmutableEdgecutFragment<OID_T,VID_T,VDATA_T,EDATA_T> frag,
                                                                                                                                                       Vertex<VID_T> vertex,
                                                                                                                                                       MSG_T msg,
                                                                                                                                                       UNUSED_T unused)

getPureMessage

<MSG_T> @com.alibaba.fastffi.FFINameAlias("GetMessage") boolean getPureMessage(MSG_T msg)

Get message into target MSG_T.

Parameters:

msg - received msg.

Returns: