Struct CompressionQueue 

pub struct CompressionQueue<const N: usize> { /* private fields */ }

A statically sized ring-buffer queue used while compressing a column.

The absolute max size of this buffer is 16 elements.

Implementations

impl<const N: usize> CompressionQueue<N>

pub const fn new() -> Self

Creates an empty queue.

pub const fn len(&self) -> usize

Returns the number of elements in the queue.

pub fn is_full(&self) -> bool

Returns true if the queue if the queue would have to overwrite an element to push a new value.

pub fn is_empty(&self) -> bool

Returns true if the queue if there is nothing to pop from the queue.

pub fn push<T: Bits + Sized>(&mut self, value: T)

Pushes a value into the queue, overwriting the oldest value if the queue is full.

pub fn pop(&mut self) -> Option<usize>

Pops the oldest value from the queue, returning None if the queue is empty.

pub fn pop_n<const M: usize>(&mut self) -> [usize; M]

Pop N values from the queue at once, values may not be meaningful if the queue is not of length N.

pub fn peak_bitcounts<const M: usize>(&mut self) -> [usize; M]

Peak N values from the queue at once, values may not be meaningful if the queue is not of length N.

Trait Implementations

impl<const N: usize> Debug for CompressionQueue<N>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl EmitDeltaBits for CompressionQueue<10>

fn emit_delta_bits(&mut self, out: &mut HalfVec) -> usize

Emits bits according to the most efficient case of Delta Compression. Returns the number of elements popped from the queue.

fn flush_delta_bits(&mut self, out: &mut HalfVec) -> usize

impl EmitDeltaDeltaBits for CompressionQueue<2>

fn emit_delta_delta_bits(&mut self, out: &mut HalfVec) -> usize

Emits bits according to the most efficient case of Delta-Delta Compression. Returns the number of elements popped from the queue.