fix: increment row count

parseablehq · Feb 21, 2025 · 6fc59d5 · 6fc59d5
1 parent 920dc40
commit 6fc59d5
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/parseable/staging/writer.rs b/src/parseable/staging/writer.rs
@@ -83,6 +83,7 @@ impl<const N: usize> DiskWriter<N> {
             }
         } else {
             self.inner.write(rb)?;
+            self.count += rb.num_rows();
         }
 
         Ok(())