(&mut self)
| 106 | } |
| 107 | |
| 108 | fn consume_batch(&mut self) -> Result<ArrayRef> { |
| 109 | let buffer = self.record_reader.consume_record_data(); |
| 110 | let null_buffer = self.record_reader.consume_bitmap_buffer(); |
| 111 | self.def_levels_buffer = self.record_reader.consume_def_levels(); |
| 112 | self.rep_levels_buffer = self.record_reader.consume_rep_levels(); |
| 113 | self.record_reader.reset(); |
| 114 | |
| 115 | let array = buffer.into_array(null_buffer, &self.data_type); |
| 116 | |
| 117 | Ok(array) |
| 118 | } |
| 119 | |
| 120 | fn skip_records(&mut self, num_records: usize) -> Result<usize> { |
| 121 | skip_records(&mut self.record_reader, self.pages.as_mut(), num_records) |
nothing calls this directly
no test coverage detected