make lint

Author: SkyFan2002

src/query/storages/fuse/src/operations/read/parquet_rows_fetcher.rs

@@ -103,7 +103,7 @@ impl<const BLOCKING_IO: bool> RowsFetcher for ParquetRowsFetcher<BLOCKING_IO> {
         for batch in part_set.iter().batching(|it| {
             let mut chunk = Vec::new();
             let mut fetch_size = 0;
-            while let Some(part) = it.next() {
+            for part in it {
                 let fuse_part = FuseBlockPartInfo::from_part(&self.part_map[part]).unwrap();
                 let in_memory_size = fuse_part.in_memory_size().unwrap_or_default();
                 if fetch_size + in_memory_size > MAX_FETCH_SIZE && !chunk.is_empty() {
@@ -112,12 +112,18 @@ impl<const BLOCKING_IO: bool> RowsFetcher for ParquetRowsFetcher<BLOCKING_IO> {
                 fetch_size += in_memory_size;
                 chunk.push(*part);
             }
-            if chunk.is_empty() { None } else { Some(chunk) }
-        }){
-            let fetch_blocks = self.fetch_blocks_in_parallel(&batch, &mut block_row_indices).await?;
+            if chunk.is_empty() {
+                None
+            } else {
+                Some(chunk)
+            }
+        }) {
+            let fetch_blocks = self
+                .fetch_blocks_in_parallel(&batch, &mut block_row_indices)
+                .await?;
             blocks.extend(fetch_blocks);
         }
-        
+
         // Take result rows from blocks.
         let indices = row_set
             .iter()
@@ -257,7 +263,11 @@ impl<const BLOCKING_IO: bool> ParquetRowsFetcher<BLOCKING_IO> {
     }
 
     #[async_backtrace::framed]
-    async fn fetch_blocks_in_parallel(&self, part_set: &[u64],block_row_indices: &mut HashMap<u64,Vec<BlockRowIndex>>)->Result<Vec<DataBlock>>{
+    async fn fetch_blocks_in_parallel(
+        &self,
+        part_set: &[u64],
+        block_row_indices: &mut HashMap<u64, Vec<BlockRowIndex>>,
+    ) -> Result<Vec<DataBlock>> {
         // parts_per_thread = num_parts / max_threads
         // remain = num_parts % max_threads
         // task distribution: