This is an automated email from the ASF dual-hosted git repository. agrove pushed a commit to branch comet-parquet-exec in repository https://gitbox.apache.org/repos/asf/datafusion-comet.git
commit fb68558ab11b66e0ec4b9f6b248d4e3c512c3869 Author: Matt Butrovich <[email protected]> AuthorDate: Sat Nov 9 09:55:58 2024 -0500 Fix Q1. --- native/core/src/execution/datafusion/planner.rs | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/native/core/src/execution/datafusion/planner.rs b/native/core/src/execution/datafusion/planner.rs index df163bef..d49d8dbb 100644 --- a/native/core/src/execution/datafusion/planner.rs +++ b/native/core/src/execution/datafusion/planner.rs @@ -961,17 +961,17 @@ impl PhysicalPlanner { &data_schema_descriptor, None, ) - .unwrap(), + .unwrap() ); println!("data_schema_arrow: {:?}", data_schema_arrow); let required_schema_descriptor = parquet::schema::types::SchemaDescriptor::new(Arc::new(required_schema)); - let required_schema_arrow = parquet::arrow::schema::parquet_to_arrow_schema( + let required_schema_arrow = Arc::new(parquet::arrow::schema::parquet_to_arrow_schema( &required_schema_descriptor, None, ) - .unwrap(); + .unwrap()); println!("required_schema_arrow: {:?}", required_schema_arrow); assert!(!required_schema_arrow.fields.is_empty()); @@ -990,7 +990,7 @@ impl PhysicalPlanner { let data_filters: Result<Vec<Arc<dyn PhysicalExpr>>, ExecutionError> = scan .data_filters .iter() - .map(|expr| self.create_expr(expr, Arc::clone(&data_schema_arrow))) + .map(|expr| self.create_expr(expr, Arc::clone(&required_schema_arrow))) .collect(); // Create a conjunctive form of the vector because ParquetExecBuilder takes --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
