Trait re_sdk::external::arrow::array::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§

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.

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.

Reads the next RecordBatch.

Trait Implementations§

§

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

Convert a RecordBatchReader into a pyarrow.RecordBatchReader.

§

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

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

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>

Implementors§