Trait datafusion::physical_plan::PhysicalExpr

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

Expression that can be evaluated against a RecordBatch A Physical expression knows its type, nullability and how to evaluate itself.

Required methods

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>

Determine whether 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...

Implementors

impl PhysicalExpr for BinaryExpr

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 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 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 IsNotNullExpr

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 IsNullExpr

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 Literal

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 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 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...