fix

Author: Rickard Lundin

src/chunked/arrow_converter.rs

@@ -236,12 +236,12 @@ impl<'a> Converter<'a> for Slice2Arrow<'a> {
     }
 
     fn setup(&mut self) -> (Sender<RecordBatch>, JoinHandle<Result<Stats>>) {
-        let o=output_factory(
+        let o = output_factory(
             self.target.clone(),
             self.masterbuilders.schema_factory(),
             self.masterbuilders.outfile.clone(),
         );
-        self.masterbuilders.sender=Some(o.0.clone());
+        self.masterbuilders.sender = Some(o.0.clone());
         o
     }
 

src/chunked/threaded_file_output.rs

@@ -137,7 +137,7 @@ impl arrow_file_output for parquet_file_out {
                 builder_write_duration: Default::default(),
             })
         });
-        self.sender=Some(sender.clone());
+        self.sender = Some(sender.clone());
         (sender, t)
     }
 }
@@ -202,7 +202,7 @@ impl arrow_file_output for ipc_file_out {
                 builder_write_duration: Default::default(),
             })
         });
-        self.sender=Some(sender.clone());
+        self.sender = Some(sender.clone());
         (sender, t)
     }
 }