Struct Runtime

pub struct Runtime { /* private fields */ }

The WASM UDF runtime.

This runtime contains an instance pool and can be shared by multiple threads.

Implementations

impl Runtime

pub fn new(binary: &[u8]) -> Result<Self>

Create a new UDF runtime from a WASM binary.

pub fn with_config(binary: &[u8], config: Config) -> Result<Self>

Create a new UDF runtime from a WASM binary with configuration.

pub fn functions(&self) -> impl Iterator<Item = &str>

Return available functions.

pub fn types(&self) -> impl Iterator<Item = (&str, &str)>

Return available types.

pub fn abi_version(&self) -> (u8, u8)

Return the ABI version.

pub fn find_function_by_inlined_signature(&self, s: &str) -> Option<&str>

Given a function signature that inlines struct types, find the function name.

Example

types = { "KeyValue": "key:string,value:string" }
input = "keyvalue(string, string) -> struct<key:string,value:string>"
output = "keyvalue(string, string) -> struct KeyValue"

pub fn call(&self, name: &str, input: &RecordBatch) -> Result<RecordBatch>

Call a function.

pub fn call_table_function<'a>( &'a self, name: &'a str, input: &'a RecordBatch, ) -> Result<impl Iterator<Item = Result<RecordBatch>> + 'a>

Call a table function.

Trait Implementations

impl Debug for Runtime

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.