Trait polars_io::ArrowReader

source ·
pub trait ArrowReader {
    // Required method
    fn next_record_batch(&mut self) -> PolarsResult<Option<RecordBatch>>;
}

Required Methods§

source

fn next_record_batch(&mut self) -> PolarsResult<Option<RecordBatch>>

Implementations on Foreign Types§

source§

impl<R> ArrowReader for FileReader<R>
where R: Read + Seek + MmapBytesReader,

Available on crate feature ipc and (crate features ipc or ipc_streaming) only.
source§

fn next_record_batch(&mut self) -> PolarsResult<Option<RecordBatch>>

source§

impl<R> ArrowReader for Reader<R>
where R: Read + Seek,

Available on crate feature avro only.
source§

fn next_record_batch(&mut self) -> PolarsResult<Option<RecordBatch>>

source§

impl<R> ArrowReader for StreamReader<R>
where R: Read,

Available on crate feature ipc_streaming and (crate features ipc or ipc_streaming) only.
source§

fn next_record_batch(&mut self) -> PolarsResult<Option<RecordBatch>>

Implementors§