(&mut self)
| 86 | } |
| 87 | |
| 88 | fn consume_batch(&mut self) -> Result<ArrayRef> { |
| 89 | // convert to arrays |
| 90 | let array = arrow_array::NullArray::new(self.record_reader.num_values()); |
| 91 | |
| 92 | // save definition and repetition buffers |
| 93 | self.def_levels_buffer = self.record_reader.consume_def_levels(); |
| 94 | self.rep_levels_buffer = self.record_reader.consume_rep_levels(); |
| 95 | |
| 96 | // Must consume bitmap buffer |
| 97 | self.record_reader.consume_bitmap_buffer(); |
| 98 | |
| 99 | self.record_reader.reset(); |
| 100 | Ok(Arc::new(array)) |
| 101 | } |
| 102 | |
| 103 | fn skip_records(&mut self, num_records: usize) -> Result<usize> { |
| 104 | skip_records(&mut self.record_reader, self.pages.as_mut(), num_records) |
nothing calls this directly
no test coverage detected