Crate risingwave_jni_core

Source

Modulesยง

jvm_runtime
macros ๐Ÿ”’
opaque_type ๐Ÿ”’
tracing_slf4j ๐Ÿ”’

Macrosยง

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

Structsยง

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.

Enumsยง

BindingError
JavaBindingIteratorInner
JniSinkWriterStreamRequest
RowExtra ๐Ÿ”’

Staticsยง

JAVA_BINDING_ASYNC_RUNTIME

Functionsยง

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

Type Aliasesยง

HummockJavaBindingIterator
JniReceiverType
JniSenderType
OwnedPointer
A pointer that owns the object it points to.
Result ๐Ÿ”’
StreamChunkRowIterator