Trait datafusion::execution::physical_plan::PhysicalExpr

pub trait PhysicalExpr: Send + Sync {
    fn name(&self) -> String;
    fn data_type(&self, input_schema: &Schema) -> Result<DataType>;
    fn nullable(&self, input_schema: &Schema) -> Result<bool>;
    fn evaluate(&self, batch: &RecordBatch) -> Result<ArrayRef>;

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

Expression that can be evaluated against a RecordBatch

Required methods

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

Loading content...

Provided methods

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

Generate schema Field type for this expression

Loading content...

Implementors

impl PhysicalExpr for Alias

fn name(&self) -> String

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

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

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

impl PhysicalExpr for BinaryExpr

fn name(&self) -> String

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

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

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

impl PhysicalExpr for CastExpr

fn name(&self) -> String

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

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

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

impl PhysicalExpr for Column

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 the expression

impl PhysicalExpr for Literal

fn name(&self) -> String

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

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

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

impl PhysicalExpr for NotExpr

fn name(&self) -> String

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

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

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

impl PhysicalExpr for ScalarFunctionExpr

fn name(&self) -> String

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

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

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

Loading content...