Trait RecordBatchReader 

pub trait RecordBatchReader: Iterator<Item = Result<RecordBatch, ArrowError>> {
    // Required method
    fn schema(&self) -> Arc<Schema> ;
}

Trait for types that can read RecordBatch’s.

To create from an iterator, see RecordBatchIterator.

Required Methods

fn schema(&self) -> Arc<Schema>

Returns the schema of this RecordBatchReader.

Implementation of this trait should guarantee that all RecordBatch’s returned by this reader should have the same schema as returned from this method.

Trait Implementations

impl IntoPyArrow for Box<dyn RecordBatchReader<Item = Result<RecordBatch, ArrowError>> + Send>

Convert a RecordBatchReader into a pyarrow.RecordBatchReader.

fn into_pyarrow<'py>(self, py: Python<'py>) -> Result<Bound<'py, PyAny>, PyErr>

Convert the implemented type into a Python object while consuming it.

impl TryFrom<Box<dyn RecordBatchReader<Item = Result<RecordBatch, ArrowError>>>> for Table

type Error = ArrowError

The type returned in the event of a conversion error.

fn try_from( value: Box<dyn RecordBatchReader<Item = Result<RecordBatch, ArrowError>>>, ) -> Result<Table, ArrowError>

Performs the conversion.

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementations on Foreign Types

impl RecordBatchReader for ParquetRecordBatchReader

fn schema(&self) -> Arc<Schema>

Returns the projected SchemaRef for reading the parquet file.

Note that the schema metadata will be stripped here. See ParquetRecordBatchReaderBuilder::schema if the metadata is desired.

impl<R> RecordBatchReader for Box<R>

where R: RecordBatchReader + ?Sized,

fn schema(&self) -> Arc<Schema>

impl<R> RecordBatchReader for Reader<R>

where R: BufRead,

fn schema(&self) -> Arc<Schema>

Implementors

impl RecordBatchReader for ArrowArrayStreamReader

impl<I> RecordBatchReader for RecordBatchIterator<I>

where I: IntoIterator<Item = Result<RecordBatch, ArrowError>>,

impl<R> RecordBatchReader for BufReader<R>

where R: BufRead,

impl<R> RecordBatchReader for FileReader<R>

where R: Read + Seek,

impl<R> RecordBatchReader for datafusion_python::datafusion_common::arrow::json::Reader<R>

where R: BufRead,

impl<R> RecordBatchReader for StreamReader<R>

where R: Read,