Trait arrow2::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>;
}

Available on crate feature io_parquet only.

A special kind of fallible streaming iterator where advance consumes the iterator.

Required Associated Types

type Item

type Error

Required Methods

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

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

Implementors

impl MutStreamingIterator for ReadColumnIterator

type Item = (IntoIter<Result<CompressedPage, Error>, Global>, ColumnChunkMetaData)

type Error = Error

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

type Item = (PageReader<R>, ColumnChunkMetaData)

type Error = Error