rebase_main

Author: coderfender

datafusion/ffi/src/config/extension_options.rs

@@ -27,7 +27,7 @@ use stabby::string::String as SString;
 use stabby::vec::Vec as SVec;
 
 use crate::df_result;
-use crate::util::{FFIResult};
+use crate::util::FFIResult;
 
 /// A stable struct for sharing [`ExtensionOptions`] across FFI boundaries.
 ///

datafusion/ffi/src/physical_optimizer.rs

@@ -28,7 +28,7 @@ use tokio::runtime::Handle;
 
 use crate::config::FFI_ConfigOptions;
 use crate::execution_plan::FFI_ExecutionPlan;
-use crate::util::{FFIResult};
+use crate::util::FFIResult;
 use crate::{df_result, sresult_return};
 
 /// A stable struct for sharing [`PhysicalOptimizerRule`] across FFI boundaries.

datafusion/ffi/src/proto/logical_extension_codec.rs

@@ -44,7 +44,7 @@ use crate::table_provider::FFI_TableProvider;
 use crate::udaf::FFI_AggregateUDF;
 use crate::udf::FFI_ScalarUDF;
 use crate::udwf::FFI_WindowUDF;
-use crate::util::{FFIResult};
+use crate::util::FFIResult;
 use crate::{df_result, sresult_return};
 
 /// A stable struct for sharing [`LogicalExtensionCodec`] across FFI boundaries.

datafusion/ffi/src/proto/physical_extension_codec.rs

@@ -37,7 +37,7 @@ use crate::execution_plan::FFI_ExecutionPlan;
 use crate::udaf::FFI_AggregateUDF;
 use crate::udf::FFI_ScalarUDF;
 use crate::udwf::FFI_WindowUDF;
-use crate::util::{FFIResult};
+use crate::util::FFIResult;
 use crate::{df_result, sresult_return};
 
 /// A stable struct for sharing [`PhysicalExtensionCodec`] across FFI boundaries.

datafusion/ffi/src/session/mod.rs

@@ -59,7 +59,7 @@ use crate::session::config::FFI_SessionConfig;
 use crate::udaf::FFI_AggregateUDF;
 use crate::udf::FFI_ScalarUDF;
 use crate::udwf::FFI_WindowUDF;
-use crate::util::{FFIResult};
+use crate::util::FFIResult;
 use crate::{df_result, sresult, sresult_return};
 
 pub mod config;

datafusion/ffi/src/table_provider_factory.rs

@@ -36,7 +36,7 @@ use crate::execution::FFI_TaskContextProvider;
 use crate::proto::logical_extension_codec::FFI_LogicalExtensionCodec;
 use crate::session::{FFI_SessionRef, ForeignSession};
 use crate::table_provider::{FFI_TableProvider, ForeignTableProvider};
-use crate::util::{FFIResult};
+use crate::util::FFIResult;
 use crate::{df_result, sresult_return};
 
 /// A stable struct for sharing [`TableProviderFactory`] across FFI boundaries.

datafusion/ffi/src/udaf/accumulator.rs

@@ -30,7 +30,7 @@ use prost::Message;
 use stabby::vec::Vec as SVec;
 
 use crate::arrow_wrappers::WrappedArray;
-use crate::util::{FFIResult};
+use crate::util::FFIResult;
 use crate::{df_result, sresult, sresult_return};
 
 /// A stable struct for sharing [`Accumulator`] across FFI boundaries.

datafusion/ffi/src/udaf/mod.rs

@@ -43,9 +43,8 @@ use std::sync::Arc;
 
 use crate::arrow_wrappers::WrappedSchema;
 use crate::util::{
-    FFI_Option, FFIResult, rvec_wrapped_to_vec_datatype,
-    rvec_wrapped_to_vec_fieldref, vec_datatype_to_rvec_wrapped,
-    vec_fieldref_to_rvec_wrapped,
+    FFI_Option, FFIResult, rvec_wrapped_to_vec_datatype, rvec_wrapped_to_vec_fieldref,
+    vec_datatype_to_rvec_wrapped, vec_fieldref_to_rvec_wrapped,
 };
 use crate::volatility::FFI_Volatility;
 use crate::{df_result, sresult, sresult_return};

datafusion/ffi/src/udtf.rs

@@ -37,7 +37,7 @@ use tokio::runtime::Handle;
 use crate::execution::FFI_TaskContextProvider;
 use crate::proto::logical_extension_codec::FFI_LogicalExtensionCodec;
 use crate::table_provider::FFI_TableProvider;
-use crate::util::{FFIResult};
+use crate::util::FFIResult;
 use crate::{df_result, sresult_return};
 
 /// A stable struct for sharing a [`TableFunctionImpl`] across FFI boundaries.

datafusion/ffi/src/udwf/mod.rs

@@ -43,9 +43,8 @@ mod range;
 
 use crate::arrow_wrappers::WrappedSchema;
 use crate::util::{
-    FFI_Option, FFIResult, rvec_wrapped_to_vec_datatype,
-    rvec_wrapped_to_vec_fieldref, vec_datatype_to_rvec_wrapped,
-    vec_fieldref_to_rvec_wrapped,
+    FFI_Option, FFIResult, rvec_wrapped_to_vec_datatype, rvec_wrapped_to_vec_fieldref,
+    vec_datatype_to_rvec_wrapped, vec_fieldref_to_rvec_wrapped,
 };
 use crate::volatility::FFI_Volatility;
 use crate::{df_result, sresult, sresult_return};