Trait datafusion::physical_plan::PhysicalExpr

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

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

Required methods

fn as_any(&self) -> &dyn Any

Returns the physical expression as Any so that it can be downcast to a specific implementation.

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

Evaluate an expression against a RecordBatch

Loading content...

Implementors

impl PhysicalExpr for BinaryExpr

fn as_any(&self) -> &dyn Any

Return a reference to Any that can be used for downcasting

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

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

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

impl PhysicalExpr for CaseExpr

fn as_any(&self) -> &dyn Any

Return a reference to Any that can be used for downcasting

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

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

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

impl PhysicalExpr for CastExpr

fn as_any(&self) -> &dyn Any

Return a reference to Any that can be used for downcasting

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

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

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

impl PhysicalExpr for Column

fn as_any(&self) -> &dyn Any

Return a reference to Any that can be used for downcasting

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

Evaluate the expression

impl PhysicalExpr for InListExpr

fn as_any(&self) -> &dyn Any

Return a reference to Any that can be used for downcasting

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

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

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

impl PhysicalExpr for IsNotNullExpr

fn as_any(&self) -> &dyn Any

Return a reference to Any that can be used for downcasting

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

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

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

impl PhysicalExpr for IsNullExpr

fn as_any(&self) -> &dyn Any

Return a reference to Any that can be used for downcasting

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

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

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

impl PhysicalExpr for Literal

fn as_any(&self) -> &dyn Any

Return a reference to Any that can be used for downcasting

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

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

fn evaluate(&self, _batch: &RecordBatch) -> Result<ColumnarValue>

impl PhysicalExpr for NegativeExpr

fn as_any(&self) -> &dyn Any

Return a reference to Any that can be used for downcasting

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

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

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

impl PhysicalExpr for NotExpr

fn as_any(&self) -> &dyn Any

Return a reference to Any that can be used for downcasting

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

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

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

impl PhysicalExpr for TryCastExpr

fn as_any(&self) -> &dyn Any

Return a reference to Any that can be used for downcasting

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

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

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

impl PhysicalExpr for ScalarFunctionExpr

fn as_any(&self) -> &dyn Any

Return a reference to Any that can be used for downcasting

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

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

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

Loading content...