Trait RecordBatchReader
pub trait RecordBatchReader: Iterator<Item = Result<RecordBatch, ArrowError>> {
// Required method
fn schema(&self) -> Arc<Schema>;
// Provided method
fn next_batch(&mut self) -> Result<Option<RecordBatch>, ArrowError> { ... }
}
Expand description
Trait for types that can read RecordBatch
’s.
To create from an iterator, see RecordBatchIterator.
Required Methods§
Provided Methods§
fn next_batch(&mut self) -> Result<Option<RecordBatch>, ArrowError>
👎Deprecated since 2.0.0: This method is deprecated in favour of next
from the trait Iterator.
fn next_batch(&mut self) -> Result<Option<RecordBatch>, ArrowError>
next
from the trait Iterator.Reads the next RecordBatch
.
Trait Implementations§
source§impl IntoPyArrow for Box<dyn RecordBatchReader + Send>
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.