Struct datafusion::execution::physical_plan::udf::ScalarFunctionExpr

pub struct ScalarFunctionExpr { /* fields omitted */ }

Scalar UDF Physical Expression

Implementations

impl ScalarFunctionExpr

pub fn new(
    name: &str,
    fun: Box<ScalarUdf>,
    args: Vec<Arc<dyn PhysicalExpr>>,
    return_type: &DataType
) -> Self

Create a new Scalar function

Trait Implementations

impl PhysicalExpr for ScalarFunctionExpr

fn name(&self) -> String

Get the name to use in a schema to represent the result of this expression

fn data_type(&self, _input_schema: &Schema) -> Result<DataType>

Get the data type of this expression, given the schema of the input

fn nullable(&self, _input_schema: &Schema) -> Result<bool>

Decide whehter this expression is nullable, given the schema of the input

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

Evaluate an expression against a RecordBatch

fn to_schema_field(&self, input_schema: &Schema) -> Result<Field>

Generate schema Field type for this expression