Trait RecordBatchReader
pub trait RecordBatchReader: Iterator<Item = Result<RecordBatch, ArrowError>> {
// Required method
fn schema(&self) -> Arc<Schema>;
}
Expand description
Trait for types that can read RecordBatch
’s.
To create from an iterator, see RecordBatchIterator.
Required Methods§
Trait Implementations§
Source§impl IntoPyArrow for Box<dyn RecordBatchReader + Send>
Convert a RecordBatchReader
into a pyarrow.RecordBatchReader
.
impl IntoPyArrow for Box<dyn RecordBatchReader + Send>
Convert a RecordBatchReader
into a pyarrow.RecordBatchReader
.
Source§fn into_pyarrow(self, py: Python<'_>) -> PyResult<PyObject>
fn into_pyarrow(self, py: Python<'_>) -> PyResult<PyObject>
Convert the implemented type into a Python object while consuming it.