Skip to main content

invoke_plugin_udf

streamling_plugin

Function invoke_plugin_udf 

Source 
pub fn invoke_plugin_udf(
    instance: &dyn ScalarUDFImpl,
    args: RVec<SafeUdfArg>,
    number_rows: usize,
) -> RResult<SafeArrowColumn, RString>
Expand description

Invokes a ScalarUDFImpl with FFI-marshaled arguments and returns the FFI-marshaled result.

This is the shared implementation behind every plugin UDF’s extern "C" invoke function. SafeUdfArg carries scalar/array semantics across the FFI boundary so plugin UDFs see the same ColumnarValue shapes as non-plugin UDFs (no unnecessary array broadcast for literals).