(schema, batches)
| 476 | |
| 477 | |
| 478 | def make_ipc_stream_reader(schema, batches): |
| 479 | return pa.ipc.open_stream(make_serialized(schema, batches)) |
| 480 | |
| 481 | |
| 482 | def make_py_record_batch_reader(schema, batches): |
nothing calls this directly
no test coverage detected