(self, requested_schema=None)
| 1217 | self.batches = batches |
| 1218 | |
| 1219 | def __arrow_c_stream__(self, requested_schema=None): |
| 1220 | reader = pa.RecordBatchReader.from_batches( |
| 1221 | self.batches[0].schema, self.batches) |
| 1222 | return reader.__arrow_c_stream__(requested_schema) |
| 1223 | |
| 1224 | data = [ |
| 1225 | pa.record_batch([pa.array([1, 2, 3], type=pa.int64())], names=['a']), |
no outgoing calls
no test coverage detected