Struct parquet::encoding::DeltaBitPackEncoder [−][src]
pub struct DeltaBitPackEncoder<T: DataType> { /* fields omitted */ }
Expand description
Delta bit packed encoder. Consists of a header followed by blocks of delta encoded values binary packed.
Delta-binary-packing:
[page-header] [block 1], [block 2], ... [block N]
Each page header consists of:
[block size] [number of miniblocks in a block] [total value count] [first value]
Each block consists of:
[min delta] [list of bitwidths of miniblocks] [miniblocks]
Current implementation writes values in put
method, multiple calls to put
to
existing block or start new block if block size is exceeded. Calling flush_buffer
writes out all data and resets internal state, including page header.
Supports only INT32 and INT64.
Implementations
impl<T: DataType> DeltaBitPackEncoder<T>
[src]
impl<T: DataType> DeltaBitPackEncoder<T>
[src]Trait Implementations
impl<T: DataType> Encoder<T> for DeltaBitPackEncoder<T>
[src]
impl<T: DataType> Encoder<T> for DeltaBitPackEncoder<T>
[src]fn estimated_data_encoded_size(&self) -> usize
[src]
fn estimated_data_encoded_size(&self) -> usize
[src]Returns an estimate of the encoded data, in bytes. Method call must be O(1). Read more
fn flush_buffer(&mut self) -> Result<ByteBufferPtr>
[src]
fn flush_buffer(&mut self) -> Result<ByteBufferPtr>
[src]Flushes the underlying byte buffer that’s being processed by this encoder, and return the immutable copy of it. This will also reset the internal state. Read more
Auto Trait Implementations
impl<T> RefUnwindSafe for DeltaBitPackEncoder<T> where
T: RefUnwindSafe,
T: RefUnwindSafe,
impl<T> Send for DeltaBitPackEncoder<T> where
T: Send,
T: Send,
impl<T> Sync for DeltaBitPackEncoder<T> where
T: Sync,
T: Sync,
impl<T> Unpin for DeltaBitPackEncoder<T> where
T: Unpin,
T: Unpin,
impl<T> UnwindSafe for DeltaBitPackEncoder<T> where
T: UnwindSafe,
T: UnwindSafe,
Blanket Implementations
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]pub fn borrow_mut(&mut self) -> &mut T
[src]
pub fn borrow_mut(&mut self) -> &mut T
[src]Mutably borrows from an owned value. Read more
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,