Package com.alibaba.graphscope.parallel
Interface MessageInBufferGen
-
- All Superinterfaces:
com.alibaba.fastffi.CXXPointer
,com.alibaba.fastffi.FFIPointer
,FFIType
,MessageInBuffer
,Serializable
- All Known Implementing Classes:
MessageInBufferGen_cxx_0x2b9fb1a1
public interface MessageInBufferGen extends MessageInBuffer
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface com.alibaba.graphscope.parallel.MessageInBuffer
MessageInBuffer.Factory
-
-
Method Summary
All Methods Instance Methods Default Methods Modifier and Type Method Description default <FRAG_T extends ArrowFragment,MSG_T,UNUSED>
@com.alibaba.fastffi.FFINameAlias("GetMessage") booleangetMessage(FRAG_T frag, Vertex<Long> vertex, MSG_T msg, UNUSED unused)
default <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") booleangetMessageArrowProjected(FRAG_T frag, Vertex<VID_T> vertex, MSG_T msg, UNUSED_T unused)
default <OID_T,VID_T,VDATA_T,EDATA_T,MSG_T,UNUSED_T>
@com.alibaba.fastffi.FFINameAlias("GetMessage") booleangetMessageImmutable(ImmutableEdgecutFragment<OID_T,VID_T,VDATA_T,EDATA_T> frag, Vertex<VID_T> vertex, MSG_T msg, UNUSED_T unused)
default <MSG_T> @com.alibaba.fastffi.FFINameAlias("GetMessage") boolean
getPureMessage(MSG_T msg)
Get message into target MSG_T.-
Methods inherited from interface com.alibaba.graphscope.parallel.MessageInBuffer
getMessage
-
-
-
-
Method Detail
-
getMessage
default <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)
- Specified by:
getMessage
in interfaceMessageInBuffer
-
getMessageArrowProjected
default <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)
- Specified by:
getMessageArrowProjected
in interfaceMessageInBuffer
-
getMessageImmutable
default <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)
- Specified by:
getMessageImmutable
in interfaceMessageInBuffer
-
getPureMessage
default <MSG_T> @com.alibaba.fastffi.FFINameAlias("GetMessage") boolean getPureMessage(MSG_T msg)
Description copied from interface:MessageInBuffer
Get message into target MSG_T.- Specified by:
getPureMessage
in interfaceMessageInBuffer
- Parameters:
msg
- received msg.- Returns:
-
-