Package com.alibaba.graphscope.parallel
Class DefaultMessageManagerGen_cxx_0xb936493c
- java.lang.Object
-
- com.alibaba.fastffi.FFIPointerImpl
-
- com.alibaba.graphscope.parallel.DefaultMessageManagerGen_cxx_0xb936493c
-
- All Implemented Interfaces:
com.alibaba.fastffi.FFIPointer
,FFIType
,DefaultMessageManager
,DefaultMessageManagerGen
,MessageManagerBase
,Serializable
public class DefaultMessageManagerGen_cxx_0xb936493c extends FFIPointerImpl implements DefaultMessageManagerGen
- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description static int
HASH_SHIFT
static int
SIZE
-
Fields inherited from class com.alibaba.fastffi.FFIPointerImpl
address
-
-
Constructor Summary
Constructors Constructor Description DefaultMessageManagerGen_cxx_0xb936493c(long address)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(Object o)
void
finishARound()
void
forceContinue()
@com.alibaba.fastffi.FFINameAlias("GetMsgSize") long
getMsgSize()
int
hashCode()
static void
nativeFinishARound(long ptr)
static void
nativeForceContinue(long ptr)
static @com.alibaba.fastffi.FFINameAlias("GetMsgSize") long
nativeGetMsgSize(long ptr)
static void
nativeStart(long ptr)
static void
nativeStartARound(long ptr)
static @com.alibaba.fastffi.FFINameAlias("ToTerminate") boolean
nativeToTerminate(long ptr)
void
start()
void
startARound()
String
toString()
@com.alibaba.fastffi.FFINameAlias("ToTerminate") boolean
toTerminate()
-
Methods inherited from class com.alibaba.fastffi.FFIPointerImpl
getAddress
-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface com.alibaba.graphscope.parallel.DefaultMessageManager
getMessage, sendMsgThroughEdges, sendMsgThroughIEdges, sendMsgThroughOEdges, syncStateOnOuterVertex
-
Methods inherited from interface com.alibaba.graphscope.parallel.DefaultMessageManagerGen
getMessageArrowProjected, getMessageImmutable, getPureMessage, sendMsgThroughEdgesArrowProjected, sendMsgThroughEdgesImmutable, sendMsgThroughIEdgesArrowProjected, sendMsgThroughIEdgesImmutable, sendMsgThroughOEdgesArrowProjected, sendMsgThroughOEdgesImmutable, sendToFragment, syncStateOnOuterVertexArrowProjected, syncStateOnOuterVertexImmutable
-
-
-
-
Method Detail
-
finishARound
public void finishARound()
- Specified by:
finishARound
in interfaceMessageManagerBase
-
nativeFinishARound
public static void nativeFinishARound(long ptr)
-
forceContinue
public void forceContinue()
- Specified by:
forceContinue
in interfaceMessageManagerBase
-
nativeForceContinue
public static void nativeForceContinue(long ptr)
-
getMsgSize
public @com.alibaba.fastffi.FFINameAlias("GetMsgSize") long getMsgSize()
- Specified by:
getMsgSize
in interfaceMessageManagerBase
-
nativeGetMsgSize
public static @com.alibaba.fastffi.FFINameAlias("GetMsgSize") long nativeGetMsgSize(long ptr)
-
start
public void start()
- Specified by:
start
in interfaceMessageManagerBase
-
nativeStart
public static void nativeStart(long ptr)
-
startARound
public void startARound()
- Specified by:
startARound
in interfaceMessageManagerBase
-
nativeStartARound
public static void nativeStartARound(long ptr)
-
toTerminate
public @com.alibaba.fastffi.FFINameAlias("ToTerminate") boolean toTerminate()
- Specified by:
toTerminate
in interfaceMessageManagerBase
-
nativeToTerminate
public static @com.alibaba.fastffi.FFINameAlias("ToTerminate") boolean nativeToTerminate(long ptr)
-
-