(schema, *iters)
| 644 | |
| 645 | |
| 646 | def _record_batch_from_iters(schema, *iters): |
| 647 | arrays = [pa.array(list(v), type=schema[i].type) |
| 648 | for i, v in enumerate(iters)] |
| 649 | return pa.RecordBatch.from_arrays(arrays=arrays, schema=schema) |
| 650 | |
| 651 | |
| 652 | def _record_batch_for_range(schema, n): |
no test coverage detected