MCPcopy Create free account
hub / github.com/apache/arrow / __arrow_c_stream__

Method __arrow_c_stream__

python/pyarrow/tests/test_ipc.py:1219–1222  ·  view source on GitHub ↗
(self, requested_schema=None)

Source from the content-addressed store, hash-verified

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']),

Calls

no outgoing calls

Tested by

no test coverage detected