(&mut self, batch: &RecordBatch)
| 279 | } |
| 280 | |
| 281 | pub fn extend(&mut self, batch: &RecordBatch) -> Result<()> { |
| 282 | self.record_batch = |
| 283 | concat_batches(&self.record_batch.schema(), [&self.record_batch, batch])?; |
| 284 | Ok(()) |
| 285 | } |
| 286 | |
| 287 | pub fn set_most_recent_row(&mut self, batch: RecordBatch) { |
| 288 | // It is enough for the batch to contain only a single row (the rest |