pub struct Runtime { /* private fields */ }
Expand description
The WASM UDF runtime.
This runtime contains an instance pool and can be shared by multiple threads.
Implementations§
Source§impl Runtime
impl Runtime
Sourcepub fn with_config(binary: &[u8], config: Config) -> Result<Self>
pub fn with_config(binary: &[u8], config: Config) -> Result<Self>
Create a new UDF runtime from a WASM binary with configuration.
Sourcepub fn abi_version(&self) -> (u8, u8)
pub fn abi_version(&self) -> (u8, u8)
Return the ABI version.
Sourcepub fn find_function(
&self,
name: &str,
arg_types: Vec<impl IntoField>,
return_type: impl IntoField,
) -> Result<FunctionHandle>
pub fn find_function( &self, name: &str, arg_types: Vec<impl IntoField>, return_type: impl IntoField, ) -> Result<FunctionHandle>
Find a function by name, argument types and return type.
The returned FunctionHandle
can be used to call the function.
Sourcepub fn find_table_function(
&self,
name: &str,
arg_types: Vec<impl IntoField>,
return_type: impl IntoField,
) -> Result<TableFunctionHandle>
pub fn find_table_function( &self, name: &str, arg_types: Vec<impl IntoField>, return_type: impl IntoField, ) -> Result<TableFunctionHandle>
Find a table function by name, argument types and return type.
The returned TableFunctionHandle
can be used to call the table function.
Sourcepub fn call(
&self,
func: &FunctionHandle,
input: &RecordBatch,
) -> Result<RecordBatch>
pub fn call( &self, func: &FunctionHandle, input: &RecordBatch, ) -> Result<RecordBatch>
Call a function.
Sourcepub fn call_table_function<'a>(
&'a self,
func: &'a TableFunctionHandle,
input: &'a RecordBatch,
) -> Result<impl Iterator<Item = Result<RecordBatch>> + 'a>
pub fn call_table_function<'a>( &'a self, func: &'a TableFunctionHandle, input: &'a RecordBatch, ) -> Result<impl Iterator<Item = Result<RecordBatch>> + 'a>
Call a table function.
Trait Implementations§
Auto Trait Implementations§
impl !Freeze for Runtime
impl !RefUnwindSafe for Runtime
impl Send for Runtime
impl Sync for Runtime
impl Unpin for Runtime
impl !UnwindSafe for Runtime
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> GetSetFdFlags for T
impl<T> GetSetFdFlags for T
Source§fn get_fd_flags(&self) -> Result<FdFlags, Error>where
T: AsFilelike,
fn get_fd_flags(&self) -> Result<FdFlags, Error>where
T: AsFilelike,
Query the “status” flags for the
self
file descriptor.Source§fn new_set_fd_flags(&self, fd_flags: FdFlags) -> Result<SetFdFlags<T>, Error>where
T: AsFilelike,
fn new_set_fd_flags(&self, fd_flags: FdFlags) -> Result<SetFdFlags<T>, Error>where
T: AsFilelike,
Source§fn set_fd_flags(&mut self, set_fd_flags: SetFdFlags<T>) -> Result<(), Error>where
T: AsFilelike,
fn set_fd_flags(&mut self, set_fd_flags: SetFdFlags<T>) -> Result<(), Error>where
T: AsFilelike,
Set the “status” flags for the
self
file descriptor. Read moreSource§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read more