Struct DefaultPhysicalExprAdapterRewriter 

struct DefaultPhysicalExprAdapterRewriter<'a> {
    logical_file_schema: &'a Schema,
    physical_file_schema: &'a Schema,
    partition_fields: &'a [(FieldRef, ScalarValue)],
}

Fields

logical_file_schema: &'a Schema

physical_file_schema: &'a Schema

partition_fields: &'a [(FieldRef, ScalarValue)]

Implementations

impl<'a> DefaultPhysicalExprAdapterRewriter<'a>

fn rewrite_expr( &self, expr: Arc<dyn PhysicalExpr>, lambdas_params: &HashSet<String>, ) -> Result<Transformed<Arc<dyn PhysicalExpr>>>

fn try_rewrite_struct_field_access( &self, expr: &Arc<dyn PhysicalExpr>, lambdas_params: &HashSet<String>, ) -> Result<Option<Arc<dyn PhysicalExpr>>>

Attempt to rewrite struct field access expressions to return null if the field does not exist in the physical schema. Note that this does not handle nested struct fields, only top-level struct field access. See https://github.com/apache/datafusion/issues/17114 for more details.

fn rewrite_column( &self, expr: Arc<dyn PhysicalExpr>, column: &Column, ) -> Result<Transformed<Arc<dyn PhysicalExpr>>>

fn get_partition_value(&self, column_name: &str) -> Option<ScalarValue>