Skip to content

Commit 9a1f59f

Browse files
committed
add comment - ensure minimum rows are collected even if memory or row limits are hit
1 parent 412ab3a commit 9a1f59f

1 file changed

Lines changed: 1 addition & 0 deletions

File tree

src/dataframe.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -902,6 +902,7 @@ async fn collect_record_batches_to_display(
902902
let mut record_batches = Vec::default();
903903
let mut has_more = false;
904904

905+
// ensure minimum rows even if memory/row limits are hit
905906
while (size_estimate_so_far < max_bytes && rows_so_far < repr_rows) || rows_so_far < min_rows {
906907
let mut rb = match stream.next().await {
907908
None => {

0 commit comments

Comments
 (0)