cargo fmt

Signed-off-by: Corwin Joy <[email protected]>

Author: corwinjoy

crates/core/src/operations/delete.rs

@@ -59,7 +59,9 @@ use crate::operations::write::WriterStatsConfig;
 use crate::operations::CustomExecuteHandler;
 use crate::protocol::DeltaOperation;
 use crate::table::config::TablePropertiesExt as _;
-use crate::table::file_format_options::{state_with_file_format_options, IntoWriterPropertiesFactoryRef, WriterPropertiesFactoryRef};
+use crate::table::file_format_options::{
+    state_with_file_format_options, IntoWriterPropertiesFactoryRef, WriterPropertiesFactoryRef,
+};
 use crate::table::state::DeltaTableState;
 use crate::{DeltaTable, DeltaTableError};
 

crates/core/src/operations/merge/mod.rs

@@ -91,7 +91,9 @@ use crate::operations::write::generated_columns::{
 use crate::operations::write::WriterStatsConfig;
 use crate::protocol::{DeltaOperation, MergePredicate};
 use crate::table::config::TablePropertiesExt as _;
-use crate::table::file_format_options::{state_with_file_format_options, IntoWriterPropertiesFactoryRef, WriterPropertiesFactoryRef};
+use crate::table::file_format_options::{
+    state_with_file_format_options, IntoWriterPropertiesFactoryRef, WriterPropertiesFactoryRef,
+};
 use crate::table::state::DeltaTableState;
 use crate::{DeltaResult, DeltaTable, DeltaTableError};
 

crates/core/src/operations/optimize.rs

@@ -63,7 +63,9 @@ use crate::kernel::{scalars::ScalarExt, Action, Add, PartitionsExt, Remove};
 use crate::logstore::{LogStore, LogStoreRef, ObjectStoreRef};
 use crate::protocol::DeltaOperation;
 use crate::table::config::TablePropertiesExt as _;
-use crate::table::file_format_options::{FileFormatRef, IntoWriterPropertiesFactoryRef, WriterPropertiesFactoryRef};
+use crate::table::file_format_options::{
+    FileFormatRef, IntoWriterPropertiesFactoryRef, WriterPropertiesFactoryRef,
+};
 use crate::table::state::DeltaTableState;
 use crate::writer::utils::arrow_schema_without_partitions;
 use crate::{crate_version, DeltaTable, ObjectMeta, PartitionFilter};
@@ -574,8 +576,7 @@ impl MergePlan {
             writer_config,
             task_parameters.num_indexed_cols,
             task_parameters.stats_columns.clone(),
-        )
-        ?;
+        )?;
 
         let mut read_stream = read_stream.await?;
 

crates/core/src/operations/update.rs

@@ -56,7 +56,9 @@ use super::{
 use crate::logstore::LogStoreRef;
 use crate::operations::cdc::*;
 use crate::protocol::DeltaOperation;
-use crate::table::file_format_options::{state_with_file_format_options, IntoWriterPropertiesFactoryRef, WriterPropertiesFactoryRef};
+use crate::table::file_format_options::{
+    state_with_file_format_options, IntoWriterPropertiesFactoryRef, WriterPropertiesFactoryRef,
+};
 use crate::table::state::DeltaTableState;
 use crate::{
     delta_datafusion::{

crates/core/src/operations/write/mod.rs

@@ -68,7 +68,9 @@ use crate::kernel::{
 };
 use crate::logstore::LogStoreRef;
 use crate::protocol::{DeltaOperation, SaveMode};
-use crate::table::file_format_options::{IntoWriterPropertiesFactoryRef, WriterPropertiesFactoryRef};
+use crate::table::file_format_options::{
+    IntoWriterPropertiesFactoryRef, WriterPropertiesFactoryRef,
+};
 use crate::DeltaTable;
 
 pub mod configs;

crates/core/src/operations/write/writer.rs

@@ -23,7 +23,9 @@ use crate::crate_version;
 use crate::errors::{DeltaResult, DeltaTableError};
 use crate::kernel::{Add, PartitionsExt};
 use crate::logstore::ObjectStoreRef;
-use crate::table::file_format_options::{IntoWriterPropertiesFactoryRef, WriterPropertiesFactoryRef};
+use crate::table::file_format_options::{
+    IntoWriterPropertiesFactoryRef, WriterPropertiesFactoryRef,
+};
 use crate::writer::record_batch::{divide_by_partition_values, PartitionResult};
 use crate::writer::stats::create_add;
 use crate::writer::utils::{
@@ -251,8 +253,7 @@ impl DeltaWriter {
                     config,
                     self.config.num_indexed_cols,
                     self.config.stats_columns.clone(),
-                )
-                ?;
+                )?;
                 writer.write(&record_batch).await?;
                 let _ = self.partition_writers.insert(partition_key, writer);
             }

crates/core/src/writer/record_batch.rs

@@ -37,7 +37,9 @@ use crate::kernel::{scalars::ScalarExt, Action, Add, PartitionsExt};
 use crate::logstore::ObjectStoreRetryExt;
 use crate::table::builder::DeltaTableBuilder;
 use crate::table::config::DEFAULT_NUM_INDEX_COLS;
-use crate::table::file_format_options::{FileFormatToWriterPropertiesFactory, IntoWriterPropertiesFactoryRef, WriterPropertiesFactoryRef};
+use crate::table::file_format_options::{
+    FileFormatToWriterPropertiesFactory, IntoWriterPropertiesFactoryRef, WriterPropertiesFactoryRef,
+};
 use crate::DeltaTable;
 
 /// Writes messages to a delta lake table.

crates/core/src/writer/utils.rs

@@ -158,7 +158,7 @@ impl Write for ShareableBuffer {
 #[cfg(test)]
 mod tests {
     use super::*;
-    use crate::table::file_format_options::{IntoWriterPropertiesFactoryRef};
+    use crate::table::file_format_options::IntoWriterPropertiesFactoryRef;
     use parquet::basic::{BrotliLevel, GzipLevel, ZstdLevel};
     use parquet::file::properties::WriterProperties;