to_pyarrow_batches
*, chunk_size=1000000, **kwargs) xorq.to_pyarrow_batches(expr,
Execute expression and return a RecordBatchReader.
This method is eager and will execute the associated expression immediately.
Parameters
Name | Type | Description | Default |
---|---|---|---|
chunk_size | int | Maximum number of rows in each returned record batch. | 1000000 |
kwargs | Any | Keyword arguments | {} |
Returns
Name | Type | Description |
---|---|---|
results | RecordBatchReader |