(&mut self, num_records: usize)
| 257 | } |
| 258 | |
| 259 | fn skip_records(&mut self, num_records: usize) -> Result<usize> { |
| 260 | let mut skipped = 0; |
| 261 | while skipped < num_records { |
| 262 | let size = std::cmp::min(num_records - skipped, self.batch_size); |
| 263 | skipped += size; |
| 264 | self.selections.append_n(size, false); |
| 265 | self.outer_position += size; |
| 266 | } |
| 267 | Ok(num_records) |
| 268 | } |
| 269 | |
| 270 | fn consume_batch(&mut self) -> Result<ArrayRef> { |
| 271 | let row_count = self.selections.len(); |