Write multiple Arrow RecordBatches.
(&mut self, batches: &[RecordBatch])
| 509 | |
| 510 | /// Write multiple Arrow RecordBatches. |
| 511 | pub async fn write_arrow(&mut self, batches: &[RecordBatch]) -> Result<()> { |
| 512 | for batch in batches { |
| 513 | self.write_arrow_batch(batch).await?; |
| 514 | } |
| 515 | Ok(()) |
| 516 | } |
| 517 | |
| 518 | /// Close all writers and collect CommitMessages for use with TableCommit. |
| 519 | /// Writers are cleared after this call, allowing the TableWrite to be reused. |
nothing calls this directly
no test coverage detected