Crate risingwave_jni_core Copy item path Source jvm_runtime macros ๐ opaque_type ๐ tracing_slf4j ๐ call_method call_static_method cast_jvalue Cast a JValueGen
to a concrete type by the given type convert_args_list Convert the argument value list when invoking a method to a list of JValue
by the argument type list in the signature for_all_native_methods Pass the information of all native methods to the callback $macro
. The input can be matched
with pattern {$({$func_name:ident, {$($ret:tt)*}, {$($args:tt)*}})*}
for_all_plain_native_methods gen_class_name Generate the dot separated java class name to the slash separated name. gen_jni_sig Generate the jni signature of a given function gen_jni_type_sig Generate the type signature of a single type gen_native_method_entry paste split_by_comma A macro that splits the input by comma and calls the callback $macro
with the split result.
The each part of the split result is within a bracket, and the callback $macro
can have its
first parameter as {$({$($args:tt)+})*}
to match the split result. split_extract_plain_native_methods Given the plain text of a list native methods, split the methods by semicolon (;), extract
the return type, argument list and name of the methods and pass the result to the callback
$macro
with the extracted result as the first parameter. The result can be matched with
pattern {$({$func_name:ident, {$($ret:tt)*}, {$($args:tt)*}})*}
to_jvalue Cast a JValueGen
to a concrete type by the given type EnvParam In most Jni interfaces, the first parameter is JNIEnv
, and the second parameter is JClass
.
This struct simply encapsulates the two common parameters into a single struct for simplicity. JavaBindingIterator JavaClassMethodCache ๐ Pointer RowCursor ๐ SliceGuard Wrapper around &[u8]
derived from jbyteArray
to prevent it from being auto-released. BindingError JavaBindingIteratorInner JniSinkWriterStreamRequest RowExtra ๐ JAVA_BINDING_ASYNC_RUNTIME Java_com_risingwave_java_binding_Binding_cdcSourceSenderClose ๐ Java_com_risingwave_java_binding_Binding_defaultVnodeCount ๐ Java_com_risingwave_java_binding_Binding_iteratorClose ๐ Java_com_risingwave_java_binding_Binding_iteratorGetArrayValue ๐ Java_com_risingwave_java_binding_Binding_iteratorGetBooleanValue ๐ Java_com_risingwave_java_binding_Binding_iteratorGetByteaValue ๐ Java_com_risingwave_java_binding_Binding_iteratorGetDateValue ๐ Java_com_risingwave_java_binding_Binding_iteratorGetDecimalValue ๐ Java_com_risingwave_java_binding_Binding_iteratorGetDoubleValue ๐ Java_com_risingwave_java_binding_Binding_iteratorGetFloatValue ๐ Java_com_risingwave_java_binding_Binding_iteratorGetInt16Value ๐ Java_com_risingwave_java_binding_Binding_iteratorGetInt32Value ๐ Java_com_risingwave_java_binding_Binding_iteratorGetInt64Value ๐ Java_com_risingwave_java_binding_Binding_iteratorGetIntervalValue ๐ Java_com_risingwave_java_binding_Binding_iteratorGetJsonbValue ๐ Java_com_risingwave_java_binding_Binding_iteratorGetKey ๐ Java_com_risingwave_java_binding_Binding_iteratorGetOp ๐ Java_com_risingwave_java_binding_Binding_iteratorGetStringValue ๐ Java_com_risingwave_java_binding_Binding_iteratorGetTimeValue ๐ Java_com_risingwave_java_binding_Binding_iteratorGetTimestampValue ๐ Java_com_risingwave_java_binding_Binding_iteratorGetTimestamptzValue ๐ Java_com_risingwave_java_binding_Binding_iteratorIsNull ๐ Java_com_risingwave_java_binding_Binding_iteratorNewStreamChunk ๐ Java_com_risingwave_java_binding_Binding_iteratorNext ๐ Java_com_risingwave_java_binding_Binding_newStreamChunkFromPayload ๐ Java_com_risingwave_java_binding_Binding_newStreamChunkFromPretty ๐ Java_com_risingwave_java_binding_Binding_recvSinkCoordinatorRequestFromChannel Java_com_risingwave_java_binding_Binding_recvSinkWriterRequestFromChannel Java_com_risingwave_java_binding_Binding_sendCdcSourceErrorToChannel ๐ Java_com_risingwave_java_binding_Binding_sendCdcSourceMsgToChannel ๐ Send messages to the channel received by CdcSplitReader
.
If msg is null, just check whether the channel is closed.
Return true if sending is successful, otherwise, return false so that caller can stop
gracefully. Java_com_risingwave_java_binding_Binding_sendSinkCoordinatorResponseToChannel Java_com_risingwave_java_binding_Binding_sendSinkWriterErrorToChannel Java_com_risingwave_java_binding_Binding_sendSinkWriterResponseToChannel Java_com_risingwave_java_binding_Binding_streamChunkClose ๐ execute_and_catch to_guarded_slice HummockJavaBindingIterator JniReceiverType JniSenderType OwnedPointer A pointer that owns the object it points to. Result ๐ StreamChunkRowIterator