(&mut self, batch_size: usize)
| 97 | /// Reads at most `batch_size` records into an arrow array and return it. |
| 98 | #[cfg(any(feature = "experimental", test))] |
| 99 | fn next_batch(&mut self, batch_size: usize) -> Result<ArrayRef> { |
| 100 | self.read_records(batch_size)?; |
| 101 | self.consume_batch() |
| 102 | } |
| 103 | |
| 104 | /// Reads at most `batch_size` records' bytes into buffer |
| 105 | /// |