Struct DefaultPhysicalExprAdapter 

pub struct DefaultPhysicalExprAdapter { /* private fields */ }

Default implementation for rewriting physical expressions to match different schemas.

Example

use datafusion_physical_expr::schema_rewriter::{DefaultPhysicalExprAdapterFactory, PhysicalExprAdapterFactory};
use arrow::datatypes::Schema;
use std::sync::Arc;

let factory = DefaultPhysicalExprAdapterFactory;
let adapter = factory.create(Arc::new(logical_file_schema.clone()), Arc::new(physical_file_schema.clone()));
let adapted_predicate = adapter.rewrite(predicate)?;

Implementations

impl DefaultPhysicalExprAdapter

pub fn new( logical_file_schema: SchemaRef, physical_file_schema: SchemaRef, ) -> Self

Create a new instance of the default physical expression adapter.

This adapter rewrites expressions to match the physical schema of the file being scanned, handling type mismatches and missing columns by filling them with default values.

Trait Implementations

impl Clone for DefaultPhysicalExprAdapter

fn clone(&self) -> DefaultPhysicalExprAdapter

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for DefaultPhysicalExprAdapter

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl PhysicalExprAdapter for DefaultPhysicalExprAdapter

fn rewrite(&self, expr: Arc<dyn PhysicalExpr>) -> Result<Arc<dyn PhysicalExpr>>

Rewrite a physical expression to match the target schema.

fn with_partition_values( &self, partition_values: Vec<(FieldRef, ScalarValue)>, ) -> Arc<dyn PhysicalExprAdapter>