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 enable Enable JVM and Java libraries. 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