Struct MultiplyScalarUdf 

pub struct MultiplyScalarUdf { /* private fields */ }

A concrete ScalarUdf that multiplies an Int64 column by a constant factor. Intended as a testable reference implementation.

Implementations

impl MultiplyScalarUdf

pub fn new( name: impl Into<String>, column: impl Into<String>, factor: i64, ) -> Self

Create a new MultiplyScalarUdf.

• name – registry name.
• column – name of the Int64 input column.
• factor – constant multiplier.

Trait Implementations

impl Debug for MultiplyScalarUdf

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

Formats the value using the given formatter.

impl ScalarUdf for MultiplyScalarUdf

fn name(&self) -> &str

Unique name used to look up this UDF in a UdfRegistry.

fn input_schema(&self) -> &Schema

The schema of the input columns this UDF expects.

fn output_field(&self) -> &Field

The output field (name + data-type) produced by this UDF.

fn call(&self, batch: &RecordBatch) -> Result<ArrayRef, UdfError>

Execute the UDF over batch, returning one value per row.

fn volatility(&self) -> Volatility

Volatility classification of the UDF (S3).