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 95d69fa30a6d975192f61f991409ab6fbed229cd Author: Matt Butrovich <[email protected]> AuthorDate: Sat Nov 9 11:00:39 2024 -0500 Clippy --- native/core/src/execution/datafusion/planner.rs | 16 +++++++++------- 1 file changed, 9 insertions(+), 7 deletions(-) diff --git a/native/core/src/execution/datafusion/planner.rs b/native/core/src/execution/datafusion/planner.rs index 6db33fad..c121e93d 100644 --- a/native/core/src/execution/datafusion/planner.rs +++ b/native/core/src/execution/datafusion/planner.rs @@ -961,17 +961,19 @@ 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 = Arc::new(parquet::arrow::schema::parquet_to_arrow_schema( - &required_schema_descriptor, - None, - ) - .unwrap()); + let required_schema_arrow = Arc::new( + parquet::arrow::schema::parquet_to_arrow_schema( + &required_schema_descriptor, + None, + ) + .unwrap(), + ); println!("required_schema_arrow: {:?}", required_schema_arrow); assert!(!required_schema_arrow.fields.is_empty()); @@ -1031,7 +1033,7 @@ impl PhysicalPlanner { .collect(); let file_scan_config = - FileScanConfig::new(object_store_url, data_schema_arrow.clone()) + FileScanConfig::new(object_store_url, Arc::clone(&data_schema_arrow)) .with_file_groups(vec![files]) .with_projection(Some(projection_vector)); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
