[chore] cargo fmt changes

Author: wilhelmagren

src/chunked/arrow_converter.rs

@@ -41,10 +41,10 @@ use std::path::PathBuf;
 use std::str::from_utf8_unchecked;
 use std::sync::Arc;
 
+use super::{ColumnBuilder, Converter, FnFindLastLineBreak, FnLineBreakLen};
+use crate::chunked;
 use crate::datatype::DataType;
 use crate::schema;
-use crate::chunked;
-use super::{ColumnBuilder, Converter, FnFindLastLineBreak, FnLineBreakLen};
 
 pub(crate) struct Slice2Arrow<'a> {
     //    pub(crate) file_out: File,
@@ -346,4 +346,4 @@ impl ColumnBuilder for HandlerBooleanBuilder {
             Arc::new(self.boolean_builder.finish()) as ArrayRef,
         )
     }
-}
+}

src/cli.rs

@@ -40,13 +40,13 @@ use std::fs::File;
 use std::path::PathBuf;
 
 #[cfg(feature = "rayon")]
-use crate::chunked::arrow_converter::{Slice2Arrow, MasterBuilders};
+use crate::chunked::arrow_converter::{MasterBuilders, Slice2Arrow};
 #[cfg(feature = "rayon")]
 use crate::chunked::converter::SampleSliceAggregator;
 #[cfg(feature = "rayon")]
-use crate::chunked::{Converter as ChunkedConverter, Slicer, find_last_nl, line_break_len_cr};
-#[cfg(feature = "rayon")]
 use crate::chunked::slicer::OldSlicer;
+#[cfg(feature = "rayon")]
+use crate::chunked::{find_last_nl, line_break_len_cr, Converter as ChunkedConverter, Slicer};
 use crate::converter::Converter;
 use crate::error::Result;
 use crate::mocker::Mocker;
@@ -265,7 +265,7 @@ impl Cli {
                     .with_thread_channel_capacity(*thread_channel_capacity)
                     .build()?
                     .convert()?;
-            },
+            }
             #[cfg(feature = "rayon")]
             Commands::CConvert {
                 converter,
@@ -295,7 +295,7 @@ impl Cli {
                             masterbuilders: master_builders,
                         });
                         s2a
-                    },
+                    }
                     Converters::None => {
                         let _out_file = fs::OpenOptions::new()
                             .create(true)
@@ -320,8 +320,7 @@ impl Cli {
                     "Operation successful inbytes={} out bytes={} num of rows={}",
                     stats.bytes_in, stats.bytes_out, stats.num_rows
                 );
-
-            },
+            }
             Commands::Mock {
                 schema,
                 out_file,
@@ -348,4 +347,4 @@ impl Cli {
 
         Ok(())
     }
-}
+}

src/datatype.rs

@@ -40,4 +40,4 @@ pub(crate) enum DataType {
     Int64,
     Utf8,
     LargeUtf8,
-}
+}

src/error.rs

@@ -75,4 +75,4 @@ mod tests_error {
             SetupError.to_string(),
         );
     }
-}
+}

src/logger.rs

@@ -145,4 +145,4 @@ pub(crate) fn try_init_logging() -> Result<(), SetLoggerError> {
     let logger = Logger::new(log_level);
     log::set_boxed_logger(Box::new(logger))
         .map(|()| log::set_max_level(log_level.to_level_filter()))
-}
+}

src/main.rs

@@ -67,4 +67,4 @@ fn main() {
         Ok(_) => info!("All done! Bye. 👋🥳"),
         Err(e) => error!("{}", e),
     }
-}
+}

src/mocker.rs

@@ -481,4 +481,4 @@ fn master_thread_write(
 
     info!("Master thread done, cleaning up resources.");
     Ok(())
-}
+}

src/mocking.rs

@@ -67,4 +67,4 @@ pub fn mock_integer(rng: &mut ThreadRng) -> String {
 /// Uniformly sample from ASCII characters and numbers to create a String with length `len`.
 pub fn mock_string(len: usize, rng: &mut ThreadRng) -> String {
     Alphanumeric.sample_string(rng, len)
-}
+}

src/parser.rs

@@ -300,4 +300,4 @@ impl LargeUtf8Parser {
             Alignment::Center => text.trim_matches::<char>(self.trim_symbol.into()),
         }
     }
-}
+}

src/schema.rs

@@ -365,4 +365,4 @@ mod tests_schema {
 
         let _schema: FixedSchema = FixedSchema::from_path(path).unwrap();
     }
-}
+}