table/ Fix paging indexing (#6850)

* table/ Fix paging indexing

close #6840

Signed-off-by: Maxim Zhiburt <zhiburt@gmail.com>

* Add test for pagging with row_overlapping

Signed-off-by: Maxim Zhiburt <zhiburt@gmail.com>

Signed-off-by: Maxim Zhiburt <zhiburt@gmail.com>
This commit is contained in:
Maxim Zhiburt 2022-10-21 19:02:25 +03:00 committed by GitHub
parent 76ccd5668a
commit 46c0d29c08
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 11 additions and 0 deletions

View File

@ -1246,6 +1246,8 @@ impl Iterator for PagingTableCreator {
} => self.build_extended(&batch, *limit, *flatten, flatten_separator.clone()),
};
self.row_offset += idx;
match table {
Ok(Some(table)) => Some(Ok(table.as_bytes().to_vec())),
Err(err) => Some(Err(err)),

File diff suppressed because one or more lines are too long