Trait polars::export::arrow::io::parquet::read::MutStreamingIterator

pub trait MutStreamingIterator {
    type Item;
    type Error;
    fn advance(self) -> Result<State<Self>, Self::Error>;
    fn get(&mut self) -> Option<&mut Self::Item>;
}

This is supported on crate feature io_parquet only.

Associated Types

type Item

type Error

Required methods

fn advance(self) -> Result<State<Self>, Self::Error>

fn get(&mut self) -> Option<&mut Self::Item>

Implementations on Foreign Types

impl<R> MutStreamingIterator for ColumnIterator<R> where
    R: Read + Seek, 

type Item = (PageIterator<R>, ColumnChunkMetaData)

type Error = ParquetError

fn advance(self) -> Result<State<ColumnIterator<R>>, ParquetError>

fn get(
    &mut self
) -> Option<&mut <ColumnIterator<R> as MutStreamingIterator>::Item>

Implementors

impl MutStreamingIterator for ReadColumnIterator

type Item = (IntoIter<Result<CompressedDataPage, ParquetError>, Global>, ColumnChunkMetaData)

type Error = ParquetError