Module udf 

ScalarUDF: Scalar User Defined Functions

Structs

AliasedScalarUDFImpl 🔒

ScalarUDF that adds an alias to the underlying function. It is better to implement ScalarUDFImpl, which supports aliases, directly if possible.

ExtendableExprSchema 🔒

A &dyn ExprSchema wrapper that supports adding the parameters of a lambda

ReturnFieldArgs

Information about arguments passed to the function

ScalarFunctionArgs

Arguments passed to ScalarUDFImpl::invoke_with_args when invoking a scalar function.

ScalarFunctionLambdaArg

A lambda argument to a ScalarFunction

ScalarUDF

Logical representation of a Scalar User Defined Function.

Enums

ValueOrLambda

ValueOrLambdaField

A tagged Field indicating whether it correspond to a value or a lambda argument

ValueOrLambdaParameter

Traits

ExtendSchema

ScalarUDFImpl

Trait for implementing user defined scalar functions.

Functions

lambda_parameters 🔒

merge_captures_with_args

Merge the lambda body captured columns with it’s arguments Datafusion relies on an unspecified field ordering implemented in this function As such, this is the only correct way to merge the captured values with the arguments The number of args should not be lower than the number of params

merge_captures_with_boxed_lazy_args

Variation of merge_captures_with_lazy_args that take boxed closures

merge_captures_with_lazy_args

Lazy version of merge_captures_with_args that receives closures to compute the arguments, and calls only the necessary to match the number of params