Trait datafusion_execution::registry::FunctionRegistry

source · 
pub trait FunctionRegistry {
    // Required methods
    fn udfs(&self) -> HashSet<String>;
    fn udf(&self, name: &str) -> Result<Arc<ScalarUDF>>;
    fn udaf(&self, name: &str) -> Result<Arc<AggregateUDF>>;
    fn udwf(&self, name: &str) -> Result<Arc<WindowUDF>>;

    // Provided methods
    fn register_udf(
        &mut self,
        _udf: Arc<ScalarUDF>
    ) -> Result<Option<Arc<ScalarUDF>>> { ... }
    fn register_udaf(
        &mut self,
        _udaf: Arc<AggregateUDF>
    ) -> Result<Option<Arc<AggregateUDF>>> { ... }
    fn register_udwf(
        &mut self,
        _udaf: Arc<WindowUDF>
    ) -> Result<Option<Arc<WindowUDF>>> { ... }
}
Expand description

A registry knows how to build logical expressions out of user-defined function’ names

Required Methods§

source

fn udfs(&self) -> HashSet<String>

Set of all available udfs.

source

fn udf(&self, name: &str) -> Result<Arc<ScalarUDF>>

Returns a reference to the user defined scalar function (udf) named name.

source

fn udaf(&self, name: &str) -> Result<Arc<AggregateUDF>>

Returns a reference to the user defined aggregate function (udaf) named name.

source

fn udwf(&self, name: &str) -> Result<Arc<WindowUDF>>

Returns a reference to the user defined window function (udwf) named name.

Provided Methods§

source

fn register_udf( &mut self, _udf: Arc<ScalarUDF> ) -> Result<Option<Arc<ScalarUDF>>>

Registers a new ScalarUDF, returning any previously registered implementation.

Returns an error (the default) if the function can not be registered, for example if the registry is read only.

source

fn register_udaf( &mut self, _udaf: Arc<AggregateUDF> ) -> Result<Option<Arc<AggregateUDF>>>

Registers a new AggregateUDF, returning any previously registered implementation.

Returns an error (the default) if the function can not be registered, for example if the registry is read only.

source

fn register_udwf( &mut self, _udaf: Arc<WindowUDF> ) -> Result<Option<Arc<WindowUDF>>>

Registers a new WindowUDF, returning any previously registered implementation.

Returns an error (the default) if the function can not be registered, for example if the registry is read only.

Implementors§