Struct UdfRegistry 

pub struct UdfRegistry { /* private fields */ }

Session-scoped UDF registry. Rust UDFs run lazily via Polars Expr::map.

Implementations

impl UdfRegistry

pub fn new() -> UdfRegistry

pub fn register_rust_udf<F>(&self, name: &str, f: F) -> Result<(), PolarsError>

where F: Fn(&[Series]) -> Result<Series, PolarsError> + Send + Sync + 'static,

Register a Rust UDF. Runs lazily when used in DataFrame operations.

pub fn get_rust_udf( &self, name: &str, case_sensitive: bool, ) -> Result<Option<Arc<dyn RustUdf>>, PolarsError>

Look up a Rust UDF by name. Case sensitivity follows session config. Returns Err if the registry lock is poisoned (e.g. a thread panicked while holding it).

pub fn has_udf( &self, name: &str, case_sensitive: bool, ) -> Result<bool, PolarsError>

Check if a Rust UDF exists. Returns Err if the registry lock is poisoned.

pub fn clear(&self) -> Result<(), PolarsError>

Clear all registered UDFs (used by SparkSession.stop()).

Trait Implementations

impl Clone for UdfRegistry

fn clone(&self) -> UdfRegistry

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for UdfRegistry

fn default() -> UdfRegistry

Returns the “default value” for a type.