cargo_fmt

Author: coderfender

datafusion/ffi/src/catalog_provider.rs

@@ -45,12 +45,12 @@ pub struct FFI_CatalogProvider {
         name: StabbyString,
     ) -> FfiOption<FFI_SchemaProvider>,
 
-    pub register_schema:
-        unsafe extern "C" fn(
-            provider: &Self,
-            name: StabbyString,
-            schema: &FFI_SchemaProvider,
-        ) -> FFIResult<FfiOption<FFI_SchemaProvider>>,
+    pub register_schema: unsafe extern "C" fn(
+        provider: &Self,
+        name: StabbyString,
+        schema: &FFI_SchemaProvider,
+    )
+        -> FFIResult<FfiOption<FFI_SchemaProvider>>,
 
     pub deregister_schema:
         unsafe extern "C" fn(

datafusion/ffi/src/catalog_provider_list.rs

@@ -47,10 +47,8 @@ pub struct FFI_CatalogProviderList {
     pub catalog_names: unsafe extern "C" fn(&Self) -> StabbyVec<StabbyString>,
 
     /// Access a catalog
-    pub catalog: unsafe extern "C" fn(
-        &Self,
-        name: StabbyString,
-    ) -> FfiOption<FFI_CatalogProvider>,
+    pub catalog:
+        unsafe extern "C" fn(&Self, name: StabbyString) -> FfiOption<FFI_CatalogProvider>,
 
     pub logical_codec: FFI_LogicalExtensionCodec,
 

datafusion/ffi/src/physical_expr/mod.rs

@@ -36,7 +36,6 @@ use datafusion_expr::statistics::Distribution;
 use datafusion_physical_expr::PhysicalExpr;
 use datafusion_physical_expr_common::physical_expr::fmt_sql;
 
-
 use stabby::string::String as StabbyString;
 use stabby::vec::Vec as StabbyVec;
 
@@ -115,8 +114,7 @@ pub struct FFI_PhysicalExpr {
 
     pub fmt_sql: unsafe extern "C" fn(&Self) -> FFIResult<StabbyString>,
 
-    pub snapshot:
-        unsafe extern "C" fn(&Self) -> FFIResult<FfiOption<FFI_PhysicalExpr>>,
+    pub snapshot: unsafe extern "C" fn(&Self) -> FFIResult<FfiOption<FFI_PhysicalExpr>>,
 
     pub snapshot_generation: unsafe extern "C" fn(&Self) -> u64,
 

datafusion/ffi/src/plan_properties.rs

@@ -47,9 +47,7 @@ pub struct FFI_PlanProperties {
 
     /// The output ordering of the plan.
     pub output_ordering:
-        unsafe extern "C" fn(
-            plan: &Self,
-        ) -> FfiOption<StabbyVec<FFI_PhysicalSortExpr>>,
+        unsafe extern "C" fn(plan: &Self) -> FfiOption<StabbyVec<FFI_PhysicalSortExpr>>,
 
     /// Return the schema of the plan.
     pub schema: unsafe extern "C" fn(plan: &Self) -> WrappedSchema,

datafusion/ffi/src/record_batch_stream.rs

@@ -25,7 +25,6 @@ use datafusion_common::{DataFusionError, Result, ffi_datafusion_err, ffi_err};
 use datafusion_execution::{RecordBatchStream, SendableRecordBatchStream};
 use futures::{Stream, TryStreamExt};
 
-
 use tokio::runtime::Handle;
 
 use crate::arrow_wrappers::{WrappedArray, WrappedSchema};

datafusion/ffi/src/schema_provider.rs

@@ -47,22 +47,21 @@ pub struct FFI_SchemaProvider {
     pub table: unsafe extern "C" fn(
         provider: &Self,
         name: StabbyString,
-    ) -> FfiFuture<
-        FFIResult<FfiOption<FFI_TableProvider>>,
-    >,
-
-    pub register_table:
-        unsafe extern "C" fn(
-            provider: &Self,
-            name: StabbyString,
-            table: FFI_TableProvider,
-        ) -> FFIResult<FfiOption<FFI_TableProvider>>,
-
-    pub deregister_table:
-        unsafe extern "C" fn(
-            provider: &Self,
-            name: StabbyString,
-        ) -> FFIResult<FfiOption<FFI_TableProvider>>,
+    )
+        -> FfiFuture<FFIResult<FfiOption<FFI_TableProvider>>>,
+
+    pub register_table: unsafe extern "C" fn(
+        provider: &Self,
+        name: StabbyString,
+        table: FFI_TableProvider,
+    )
+        -> FFIResult<FfiOption<FFI_TableProvider>>,
+
+    pub deregister_table: unsafe extern "C" fn(
+        provider: &Self,
+        name: StabbyString,
+    )
+        -> FFIResult<FfiOption<FFI_TableProvider>>,
 
     pub table_exist: unsafe extern "C" fn(provider: &Self, name: StabbyString) -> bool,
 

datafusion/ffi/src/table_provider.rs

@@ -36,7 +36,6 @@ use datafusion_proto::logical_plan::{
 use datafusion_proto::protobuf::LogicalExprList;
 use prost::Message;
 
-
 use stabby::vec::Vec as StabbyVec;
 use tokio::runtime::Handle;
 
@@ -46,7 +45,7 @@ use crate::arrow_wrappers::WrappedSchema;
 use crate::execution::FFI_TaskContextProvider;
 use crate::proto::logical_extension_codec::FFI_LogicalExtensionCodec;
 use crate::session::{FFI_SessionRef, ForeignSession};
-use crate::table_source::{FfiTableProviderFilterPushDown, FFI_TableType};
+use crate::table_source::{FFI_TableType, FfiTableProviderFilterPushDown};
 use crate::util::{FFIResult, FfiOption, FfiResult};
 use crate::{df_result, rresult_return};
 
@@ -517,7 +516,10 @@ impl TableProvider for ForeignTableProvider {
             };
             let serialized_filters = expr_list.encode_to_vec();
 
-            let pushdowns = df_result!(pushdown_fn(&self.0, serialized_filters.into_iter().collect()))?;
+            let pushdowns = df_result!(pushdown_fn(
+                &self.0,
+                serialized_filters.into_iter().collect()
+            ))?;
 
             Ok(pushdowns.iter().map(|v| v.into()).collect())
         }

datafusion/ffi/src/table_provider_factory.rs

@@ -62,9 +62,7 @@ pub struct FFI_TableProviderFactory {
         factory: &Self,
         session: FFI_SessionRef,
         cmd_serialized: StabbyVec<u8>,
-    ) -> FfiFuture<
-        FFIResult<FFI_TableProvider>,
-    >,
+    ) -> FfiFuture<FFIResult<FFI_TableProvider>>,
 
     logical_codec: FFI_LogicalExtensionCodec,
 

datafusion/ffi/src/udaf/mod.rs

@@ -34,7 +34,6 @@ use datafusion_proto_common::from_proto::parse_proto_fields_to_fields;
 use groups_accumulator::FFI_GroupsAccumulator;
 use prost::{DecodeError, Message};
 
-
 use stabby::str::Str as StabbyStr;
 use stabby::string::String as StabbyString;
 use stabby::vec::Vec as StabbyVec;
@@ -44,8 +43,9 @@ use std::sync::Arc;
 
 use crate::arrow_wrappers::WrappedSchema;
 use crate::util::{
-    FFIResult, FfiOption, FfiResult, rvec_wrapped_to_vec_datatype, rvec_wrapped_to_vec_fieldref,
-    vec_datatype_to_rvec_wrapped, vec_fieldref_to_rvec_wrapped,
+    FFIResult, FfiOption, FfiResult, rvec_wrapped_to_vec_datatype,
+    rvec_wrapped_to_vec_fieldref, vec_datatype_to_rvec_wrapped,
+    vec_fieldref_to_rvec_wrapped,
 };
 use crate::volatility::FfiVolatility;
 use crate::{df_result, rresult, rresult_return};

datafusion/ffi/src/udf/mod.rs

@@ -35,7 +35,6 @@ use return_type_args::{
     FFI_ReturnFieldArgs, ForeignReturnFieldArgs, ForeignReturnFieldArgsOwned,
 };
 
-
 use stabby::string::String as StabbyString;
 use stabby::vec::Vec as StabbyVec;