pub struct Compressor<I> where
I: Iterator<Item = Result<EncodedPage, Error>>, { /* private fields */ }
io_parquet
only.Expand description
A FallibleStreamingIterator
that consumes EncodedPage
and yields CompressedPage
holding a reusable buffer (Vec<u8>
) for compression.
Implementations
impl<I> Compressor<I> where
I: Iterator<Item = Result<EncodedPage, Error>>,
impl<I> Compressor<I> where
I: Iterator<Item = Result<EncodedPage, Error>>,
pub fn new(
iter: I,
compression: CompressionOptions,
buffer: Vec<u8, Global>
) -> Compressor<I>
pub fn new(
iter: I,
compression: CompressionOptions,
buffer: Vec<u8, Global>
) -> Compressor<I>
Creates a new Compressor
pub fn new_from_vec(
iter: I,
compression: CompressionOptions,
buffer: Vec<u8, Global>
) -> Compressor<I>
pub fn new_from_vec(
iter: I,
compression: CompressionOptions,
buffer: Vec<u8, Global>
) -> Compressor<I>
Creates a new Compressor
(same as new
)
pub fn into_inner(self) -> (I, Vec<u8, Global>)
pub fn into_inner(self) -> (I, Vec<u8, Global>)
Deconstructs itself into its iterator and scratch buffer.
Trait Implementations
impl<I> FallibleStreamingIterator for Compressor<I> where
I: Iterator<Item = Result<EncodedPage, Error>>,
impl<I> FallibleStreamingIterator for Compressor<I> where
I: Iterator<Item = Result<EncodedPage, Error>>,
type Item = CompressedPage
type Item = CompressedPage
The type being iterated over.
fn advance(
&mut self
) -> Result<(), <Compressor<I> as FallibleStreamingIterator>::Error>
fn advance(
&mut self
) -> Result<(), <Compressor<I> as FallibleStreamingIterator>::Error>
Advances the iterator to the next position. Read more
fn get(&self) -> Option<&<Compressor<I> as FallibleStreamingIterator>::Item>
fn get(&self) -> Option<&<Compressor<I> as FallibleStreamingIterator>::Item>
Returns the current element. Read more
sourcefn 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
sourcefn size_hint(&self) -> (usize, Option<usize>)
fn size_hint(&self) -> (usize, Option<usize>)
Returns bounds on the number of remaining elements in the iterator.
sourcefn all<F>(&mut self, f: F) -> Result<bool, Self::Error> where
F: FnMut(&Self::Item) -> bool,
fn all<F>(&mut self, f: F) -> Result<bool, Self::Error> where
F: FnMut(&Self::Item) -> bool,
Determines if all elements of the iterator satisfy a predicate.
sourcefn any<F>(&mut self, f: F) -> Result<bool, Self::Error> where
F: FnMut(&Self::Item) -> bool,
fn any<F>(&mut self, f: F) -> Result<bool, Self::Error> where
F: FnMut(&Self::Item) -> bool,
Determines if any elements of the iterator satisfy a predicate.
sourcefn count(self) -> Result<usize, Self::Error>
fn count(self) -> Result<usize, Self::Error>
Returns the number of remaining elements in the iterator.
sourcefn filter<F>(self, f: F) -> Filter<Self, F> where
F: FnMut(&Self::Item) -> bool,
fn filter<F>(self, f: F) -> Filter<Self, F> where
F: FnMut(&Self::Item) -> bool,
Returns an iterator which filters elements by a predicate.
sourcefn find<F>(&mut self, f: F) -> Result<Option<&Self::Item>, Self::Error> where
F: FnMut(&Self::Item) -> bool,
fn find<F>(&mut self, f: F) -> Result<Option<&Self::Item>, Self::Error> where
F: FnMut(&Self::Item) -> bool,
Returns the first element of the iterator which satisfies a predicate.
sourcefn for_each<F>(self, f: F) -> Result<(), Self::Error> where
F: FnMut(&Self::Item),
fn for_each<F>(self, f: F) -> Result<(), Self::Error> where
F: FnMut(&Self::Item),
Calls a closure on each element of an iterator.
sourcefn fuse(self) -> Fuse<Self>
fn fuse(self) -> Fuse<Self>
Returns an iterator which is well-behaved at the beginning and end of iteration.
sourcefn map<F, B>(self, f: F) -> Map<Self, F, B> where
F: FnMut(&Self::Item) -> B,
fn map<F, B>(self, f: F) -> Map<Self, F, B> where
F: FnMut(&Self::Item) -> B,
Returns an iterator which applies a transform to elements.
sourcefn map_ref<F, B>(self, f: F) -> MapRef<Self, F> where
F: Fn(&Self::Item) -> &B,
B: ?Sized,
fn map_ref<F, B>(self, f: F) -> MapRef<Self, F> where
F: Fn(&Self::Item) -> &B,
B: ?Sized,
Returns an iterator which applies a transform to elements. Read more
sourcefn map_err<F, B>(self, f: F) -> MapErr<Self, F> where
F: Fn(Self::Error) -> B,
fn map_err<F, B>(self, f: F) -> MapErr<Self, F> where
F: Fn(Self::Error) -> B,
Returns an iterator that applies a transform to errors.
sourcefn 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.
sourcefn position<F>(&mut self, f: F) -> Result<Option<usize>, Self::Error> where
F: FnMut(&Self::Item) -> bool,
fn position<F>(&mut self, f: F) -> Result<Option<usize>, Self::Error> where
F: FnMut(&Self::Item) -> bool,
Returns the position of the first element matching a predicate.
sourcefn skip_while<F>(self, f: F) -> SkipWhile<Self, F> where
F: FnMut(&Self::Item) -> bool,
fn skip_while<F>(self, f: F) -> SkipWhile<Self, F> where
F: FnMut(&Self::Item) -> bool,
Returns an iterator which skips the first sequence of elements matching a predicate.
Auto Trait Implementations
impl<I> RefUnwindSafe for Compressor<I> where
I: RefUnwindSafe,
impl<I> Send for Compressor<I> where
I: Send,
impl<I> Sync for Compressor<I> where
I: Sync,
impl<I> Unpin for Compressor<I> where
I: Unpin,
impl<I> UnwindSafe for Compressor<I> where
I: UnwindSafe,
Blanket Implementations
sourceimpl<T> BorrowMut<T> for T where
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
const: unstable · sourcefn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more