Struct datafusion::physical_plan::udf::ScalarUDF

pub struct ScalarUDF { /* private fields */ }

Logical representation of a Scalar User Defined Function.

A scalar function produces a single row output for each row of input. This struct contains the information DataFusion needs to plan and invoke functions you supply such name, type signature, return type, and actual implementation.

1. For simple use cases, use create_udf (examples in simple_udf.rs).

2. For advanced use cases, use ScalarUDFImpl which provides full API access (examples in advanced_udf.rs).

API Note

This is a separate struct from ScalarUDFImpl to maintain backwards compatibility with the older API.

Implementations

impl ScalarUDF

pub fn new( name: &str, signature: &Signature, return_type: &Arc<dyn Fn(&[DataType]) -> Result<Arc<DataType>, DataFusionError> + Send + Sync>, fun: &Arc<dyn Fn(&[ColumnarValue]) -> Result<ColumnarValue, DataFusionError> + Send + Sync> ) -> ScalarUDF

👎Deprecated since 34.0.0: please implement ScalarUDFImpl instead

Create a new ScalarUDF from low level details.

See ScalarUDFImpl for a more convenient way to create a ScalarUDF using trait objects

pub fn new_from_impl<F>(fun: F) -> ScalarUDF

where F: ScalarUDFImpl + 'static,

Create a new ScalarUDF from a [ScalarUDFImpl] trait object

Note this is the same as using the From impl (ScalarUDF::from)

pub fn inner(&self) -> Arc<dyn ScalarUDFImpl>

Return the underlying ScalarUDFImpl trait object for this function

pub fn with_aliases( self, aliases: impl IntoIterator<Item = &'static str> ) -> ScalarUDF

Adds additional names that can be used to invoke this function, in addition to name

If you implement ScalarUDFImpl directly you should return aliases directly.

pub fn call(&self, args: Vec<Expr>) -> Expr

Returns a Expr logical expression to call this UDF with specified arguments.

This utility allows using the UDF without requiring access to the registry.

pub fn name(&self) -> &str

Returns this function’s name.

See ScalarUDFImpl::name for more details.

pub fn aliases(&self) -> &[String]

Returns the aliases for this function.

See ScalarUDF::with_aliases for more details

pub fn signature(&self) -> &Signature

Returns this function’s Signature (what input types are accepted).

See ScalarUDFImpl::signature for more details.

pub fn return_type_from_exprs( &self, args: &[Expr], schema: &dyn ExprSchema, arg_types: &[DataType] ) -> Result<DataType, DataFusionError>

The datatype this function returns given the input argument input types. This function is used when the input arguments are Exprs.

See ScalarUDFImpl::return_type_from_exprs for more details.

pub fn simplify( &self, args: Vec<Expr>, info: &dyn SimplifyInfo ) -> Result<ExprSimplifyResult, DataFusionError>

Do the function rewrite

See ScalarUDFImpl::simplify for more details.

pub fn invoke( &self, args: &[ColumnarValue] ) -> Result<ColumnarValue, DataFusionError>

Invoke the function on args, returning the appropriate result.

See ScalarUDFImpl::invoke for more details.

pub fn fun( &self ) -> Arc<dyn Fn(&[ColumnarValue]) -> Result<ColumnarValue, DataFusionError> + Send + Sync>

Returns a ScalarFunctionImplementation that can invoke the function during execution

pub fn monotonicity(&self) -> Result<Option<Vec<Option<bool>>>, DataFusionError>

This function specifies monotonicity behaviors for User defined scalar functions.

See ScalarUDFImpl::monotonicity for more details.

Trait Implementations

impl Clone for ScalarUDF

fn clone(&self) -> ScalarUDF

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ScalarUDF

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

Formats the value using the given formatter.

impl<F> From<F> for ScalarUDF

where F: ScalarUDFImpl + Send + Sync + 'static,

fn from(fun: F) -> ScalarUDF

Converts to this type from the input type.

impl Hash for ScalarUDF

fn hash<H>(&self, state: &mut H)

where H: Hasher,

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl PartialEq for ScalarUDF

fn eq(&self, other: &ScalarUDF) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for ScalarUDF