fix: don't drop in-memory records

de-sh · de-sh · commit 240eb99d9a22 · 2025-02-21T16:18:06.000+05:30
diff --git a/src/parseable/streams.rs b/src/parseable/streams.rs
@@ -355,7 +355,7 @@ impl Stream {
         let arrow_files = self.arrow_files();
         let record_reader = MergedRecordReader::new(&arrow_files);
         if record_reader.readers.is_empty() {
-            return vec![];
+            return records;
         }
         let mut from_file = record_reader
             .merged_iter(schema.clone(), time_partition)

Original file line number	Diff line number	Diff line change
`@@ -355,7 +355,7 @@ impl Stream {`
`355`	`355`	`let arrow_files = self.arrow_files();`
`356`	`356`	`let record_reader = MergedRecordReader::new(&arrow_files);`
`357`	`357`	`if record_reader.readers.is_empty() {`
`358`		`- return vec![];`
	`358`	`+ return records;`
`359`	`359`	`}`
`360`	`360`	`let mut from_file = record_reader`
`361`	`361`	`.merged_iter(schema.clone(), time_partition)`