Struct parquet2::read::BasicDecompressor
source · pub struct BasicDecompressor<I: Iterator<Item = Result<CompressedPage>>> { /* private fields */ }
Expand description
A FallibleStreamingIterator
that decompresses CompressedPage
into DataPage
.
Implementation
This decompressor uses an internal Vec<u8>
to perform decompressions which
is re-used across pages, so that a single allocation is required.
If the pages are not compressed, the internal buffer is not used.
Implementations§
source§impl<I> BasicDecompressor<I>where
I: Iterator<Item = Result<CompressedPage>>,
impl<I> BasicDecompressor<I>where I: Iterator<Item = Result<CompressedPage>>,
sourcepub fn new(iter: I, buffer: Vec<u8>) -> Self
pub fn new(iter: I, buffer: Vec<u8>) -> Self
Returns a new BasicDecompressor
.
sourcepub fn into_inner(self) -> Vec<u8>
pub fn into_inner(self) -> Vec<u8>
Returns its internal buffer, consuming itself.
Trait Implementations§
source§impl<I> FallibleStreamingIterator for BasicDecompressor<I>where
I: Iterator<Item = Result<CompressedPage>>,
impl<I> FallibleStreamingIterator for BasicDecompressor<I>where I: Iterator<Item = Result<CompressedPage>>,
source§fn next(&mut self) -> Result<Option<&Self::Item>, Self::Error>
fn next(&mut self) -> Result<Option<&Self::Item>, Self::Error>
Advances the iterator, returning the next element. Read more
source§fn size_hint(&self) -> (usize, Option<usize>)
fn size_hint(&self) -> (usize, Option<usize>)
Returns bounds on the number of remaining elements in the iterator.
source§fn all<F>(&mut self, f: F) -> Result<bool, Self::Error>where
Self: Sized,
F: FnMut(&Self::Item) -> bool,
fn all<F>(&mut self, f: F) -> Result<bool, Self::Error>where Self: Sized, F: FnMut(&Self::Item) -> bool,
Determines if all elements of the iterator satisfy a predicate.
source§fn any<F>(&mut self, f: F) -> Result<bool, Self::Error>where
Self: Sized,
F: FnMut(&Self::Item) -> bool,
fn any<F>(&mut self, f: F) -> Result<bool, Self::Error>where Self: Sized, F: FnMut(&Self::Item) -> bool,
Determines if any elements of the iterator satisfy a predicate.
source§fn by_ref(&mut self) -> &mut Selfwhere
Self: Sized,
fn by_ref(&mut self) -> &mut Selfwhere Self: Sized,
Borrows an iterator, rather than consuming it. Read more
source§fn count(self) -> Result<usize, Self::Error>where
Self: Sized,
fn count(self) -> Result<usize, Self::Error>where Self: Sized,
Returns the number of remaining elements in the iterator.
source§fn filter<F>(self, f: F) -> Filter<Self, F>where
Self: Sized,
F: FnMut(&Self::Item) -> bool,
fn filter<F>(self, f: F) -> Filter<Self, F>where Self: Sized, F: FnMut(&Self::Item) -> bool,
Returns an iterator which filters elements by a predicate.
source§fn find<F>(&mut self, f: F) -> Result<Option<&Self::Item>, Self::Error>where
Self: Sized,
F: FnMut(&Self::Item) -> bool,
fn find<F>(&mut self, f: F) -> Result<Option<&Self::Item>, Self::Error>where Self: Sized, F: FnMut(&Self::Item) -> bool,
Returns the first element of the iterator which satisfies a predicate.
source§fn for_each<F>(self, f: F) -> Result<(), Self::Error>where
Self: Sized,
F: FnMut(&Self::Item),
fn for_each<F>(self, f: F) -> Result<(), Self::Error>where Self: Sized, F: FnMut(&Self::Item),
Calls a closure on each element of an iterator.
source§fn fuse(self) -> Fuse<Self>where
Self: Sized,
fn fuse(self) -> Fuse<Self>where Self: Sized,
Returns an iterator which is well-behaved at the beginning and end of iteration.
source§fn map<F, B>(self, f: F) -> Map<Self, F, B>where
Self: Sized,
F: FnMut(&Self::Item) -> B,
fn map<F, B>(self, f: F) -> Map<Self, F, B>where Self: Sized, F: FnMut(&Self::Item) -> B,
Returns an iterator which applies a transform to elements.
source§fn map_ref<F, B>(self, f: F) -> MapRef<Self, F>where
Self: Sized,
F: Fn(&Self::Item) -> &B,
B: ?Sized,
fn map_ref<F, B>(self, f: F) -> MapRef<Self, F>where Self: Sized, F: Fn(&Self::Item) -> &B, B: ?Sized,
Returns an iterator which applies a transform to elements. Read more
source§fn map_err<F, B>(self, f: F) -> MapErr<Self, F>where
Self: Sized,
F: Fn(Self::Error) -> B,
fn map_err<F, B>(self, f: F) -> MapErr<Self, F>where Self: Sized, F: Fn(Self::Error) -> B,
Returns an iterator that applies a transform to errors.
source§fn nth(&mut self, n: usize) -> Result<Option<&Self::Item>, Self::Error>
fn nth(&mut self, n: usize) -> Result<Option<&Self::Item>, Self::Error>
Returns the
nth
element of the iterator.source§fn position<F>(&mut self, f: F) -> Result<Option<usize>, Self::Error>where
Self: Sized,
F: FnMut(&Self::Item) -> bool,
fn position<F>(&mut self, f: F) -> Result<Option<usize>, Self::Error>where Self: Sized, F: FnMut(&Self::Item) -> bool,
Returns the position of the first element matching a predicate.
source§fn skip(self, n: usize) -> Skip<Self>where
Self: Sized,
fn skip(self, n: usize) -> Skip<Self>where Self: Sized,
Returns an iterator which skips the first
n
elements.source§fn skip_while<F>(self, f: F) -> SkipWhile<Self, F>where
Self: Sized,
F: FnMut(&Self::Item) -> bool,
fn skip_while<F>(self, f: F) -> SkipWhile<Self, F>where Self: Sized, F: FnMut(&Self::Item) -> bool,
Returns an iterator which skips the first sequence of elements matching a predicate.