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 evaluate(&self, batch: &RecordBatch) -> Result<ArrayRef>;
}

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 evaluate(&self, batch: &RecordBatch) -> Result<ArrayRef>

Evaluate an expression against a RecordBatch

Loading content...

Implementors

impl PhysicalExpr for BinaryExpr

fn name(&self) -> String

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

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 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 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 evaluate(&self, batch: &RecordBatch) -> Result<ArrayRef>

Loading content...