Merge branch 'main' into feat_migrate_ffi_to_stabby

Author: coderfender

Cargo.lock

@@ -462,7 +462,7 @@ mod tests {
     use std::ops::Not;
 
     use super::*;
-    use datafusion_expr::{Expr, case, col, lit};
+    use datafusion_expr::{case, col};
 
     #[test]
     fn test_split_files() {

datafusion/catalog-listing/src/helpers.rs

@@ -920,7 +920,6 @@ mod tests {
     use arrow::compute::SortOptions;
     use datafusion_physical_expr::expressions::Column;
     use datafusion_physical_expr_common::sort_expr::PhysicalSortExpr;
-    use std::sync::Arc;
 
     /// Helper to create a PhysicalSortExpr
     fn sort_expr(

datafusion/catalog-listing/src/table.rs

@@ -1088,6 +1088,12 @@ config_namespace! {
         /// process to reorder the join keys
         pub top_down_join_key_reordering: bool, default = true
 
+        /// When set to true, the physical plan optimizer may swap join inputs
+        /// based on statistics. When set to false, statistics-driven join
+        /// input reordering is disabled and the original join order in the
+        /// query is used.
+        pub join_reordering: bool, default = true
+
         /// When set to true, the physical plan optimizer will prefer HashJoin over SortMergeJoin.
         /// HashJoin can work more efficiently than SortMergeJoin but consumes more memory
         pub prefer_hash_join: bool, default = true

datafusion/common/src/config.rs

@@ -5336,7 +5336,6 @@ impl ScalarType<i32> for Date32Type {
 
 #[cfg(test)]
 mod tests {
-    use std::sync::Arc;
 
     use super::*;
     use crate::cast::{as_list_array, as_map_array, as_struct_array};
@@ -5354,7 +5353,6 @@ mod tests {
     };
     use arrow::error::ArrowError;
     use arrow::util::pretty::pretty_format_columns;
-    use chrono::NaiveDate;
     use insta::assert_snapshot;
     use rand::Rng;
 

datafusion/common/src/scalar/mod.rs

@@ -143,7 +143,7 @@ mod tests {
         LogicalField, LogicalFields, logical_boolean, logical_date, logical_float32,
         logical_float64, logical_int32, logical_int64, logical_null, logical_string,
     };
-    use arrow::datatypes::{DataType, Field, Fields};
+    use arrow::datatypes::{Field, Fields};
     use insta::assert_snapshot;
 
     #[test]

datafusion/common/src/types/logical.rs

@@ -565,7 +565,6 @@ impl NativeType {
 mod tests {
     use super::*;
     use crate::types::LogicalField;
-    use arrow::datatypes::Field;
     use insta::assert_snapshot;
 
     #[test]

datafusion/common/src/types/native.rs

@@ -107,7 +107,6 @@ impl DataFrame {
 #[cfg(test)]
 mod tests {
     use std::collections::HashMap;
-    use std::sync::Arc;
 
     use super::super::Result;
     use super::*;

datafusion/core/src/dataframe/parquet.rs

@@ -557,17 +557,13 @@ mod tests {
 
     #[tokio::test]
     async fn test_create_with_invalid_session() {
-        use async_trait::async_trait;
-        use datafusion_catalog::Session;
-        use datafusion_common::Result;
         use datafusion_common::config::TableOptions;
         use datafusion_execution::TaskContext;
         use datafusion_execution::config::SessionConfig;
         use datafusion_physical_expr::PhysicalExpr;
         use datafusion_physical_plan::ExecutionPlan;
         use std::any::Any;
         use std::collections::HashMap;
-        use std::sync::Arc;
 
         // A mock Session that is NOT SessionState
         #[derive(Debug)]

datafusion/core/src/datasource/listing_table_factory.rs

@@ -557,7 +557,7 @@ mod tests {
     use datafusion_expr::execution_props::ExecutionProps;
     use datafusion_expr::{AggregateUDF, Expr, LogicalPlan, ScalarUDF, WindowUDF};
     use datafusion_physical_expr_common::physical_expr::PhysicalExpr;
-    use object_store::{chunked::ChunkedStore, memory::InMemory, path::Path};
+    use object_store::{chunked::ChunkedStore, memory::InMemory};
 
     struct MockSession {
         config: SessionConfig,