Fix rust fmt

Author: Kazantsev Maksim

native/core/src/execution/operators/mod.rs

@@ -31,9 +31,9 @@ pub use expand::ExpandExec;
 mod iceberg_scan;
 mod parquet_writer;
 pub use parquet_writer::ParquetWriterExec;
+mod csv_scan;
 pub mod projection;
 mod scan;
-mod csv_scan;
 pub use csv_scan::init_csv_datasource_exec;
 
 /// Error returned during executing operators.

native/core/src/execution/planner.rs

@@ -21,8 +21,8 @@ pub mod expression_registry;
 pub mod macros;
 pub mod operator_registry;
 
-use crate::execution::operators::IcebergScanExec;
 use crate::execution::operators::init_csv_datasource_exec;
+use crate::execution::operators::IcebergScanExec;
 use crate::{
     errors::ExpressionError,
     execution::{
@@ -1123,8 +1123,10 @@ impl PhysicalPlanner {
                 ))
             }
             OpStruct::CsvScan(scan) => {
-                let data_schema = convert_spark_types_to_arrow_schema(scan.required_schema.as_slice());
-                let partition_schema = convert_spark_types_to_arrow_schema(scan.partition_schema.as_slice());
+                let data_schema =
+                    convert_spark_types_to_arrow_schema(scan.required_schema.as_slice());
+                let partition_schema =
+                    convert_spark_types_to_arrow_schema(scan.partition_schema.as_slice());
                 let object_store_options: HashMap<String, String> = scan
                     .object_store_options
                     .iter()
@@ -1149,7 +1151,7 @@ impl PhysicalPlanner {
                     file_groups,
                     data_schema,
                     Some(partition_schema),
-                    &scan.csv_options.clone().unwrap()
+                    &scan.csv_options.clone().unwrap(),
                 )?;
                 Ok((
                     vec![],

native/core/src/execution/planner/operator_registry.rs

@@ -152,6 +152,6 @@ fn get_operator_type(spark_operator: &Operator) -> Option<OperatorType> {
         OpStruct::HashJoin(_) => Some(OperatorType::HashJoin),
         OpStruct::Window(_) => Some(OperatorType::Window),
         OpStruct::Explode(_) => None, // Not yet in OperatorType enum
-        OpStruct::CsvScan(_) => Some(OperatorType::CsvScan)
+        OpStruct::CsvScan(_) => Some(OperatorType::CsvScan),
     }
 }