fmt

jorgecarleitao · Jun 5, 2022 · 93fda32 · 93fda32
1 parent 753a4ce
commit 93fda32
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/src/io/parquet/read/row_group.rs b/src/io/parquet/read/row_group.rs
@@ -78,10 +78,11 @@ impl Iterator for RowGroupDeserializer {
             })
             .collect::<Result<Vec<_>>>()
             .map(Chunk::new);
-        self.remaining_rows = self.remaining_rows.saturating_sub(chunk
-            .as_ref()
-            .map(|x| x.len())
-            .unwrap_or(self.remaining_rows)
+        self.remaining_rows = self.remaining_rows.saturating_sub(
+            chunk
+                .as_ref()
+                .map(|x| x.len())
+                .unwrap_or(self.remaining_rows),
         );
 
         Some(chunk)