Skip to main content

VarVecSeqReader

Struct VarVecSeqReader 

Source
pub struct VarVecSeqReader<'a, T: Storable, E: Endianness, B: AsRef<[u64]>>
where for<'b> BufBitReader<E, MemWordReader<u64, &'b [u64], true>, DefaultReadParams>: BitRead<E, Error = Infallible> + CodesRead<E> + BitSeek<Error = Infallible>,
{ /* private fields */ }
Expand description

A stateful, sequential reader for an VarVec optimized for forward access.

This reader is created by the seq_reader method. It maintains an internal cursor corresponding to the last-read element’s position, making it highly efficient for sequential or mostly-forward access patterns.

It is a more specialized tool than VarVecReader.

§Performance

VarVecSeqReader maintains an internal state of the current decoding position. When a new get request is made, it decides whether to:

  1. Decode Forward (Fast Path): If the requested index is at or after the current position and within the same sample block, the reader decodes forward from its last position. This avoids a costly seek operation and is the primary optimization.

  2. Seek and Decode (Fallback): If the requested index is far away or requires moving backward, the reader falls back to seeking to the nearest sample point and decoding from there, just like VarVecReader.

§Examples

use compressed_intvec::variable::{VarVec, UVarVec};

let data: Vec<u32> = (0..100).collect();
let vec: UVarVec<u32> = VarVec::from_slice(&data)?;

// Create a reader optimized for sequential access
let mut seq_reader = vec.seq_reader();

// Accessing indices in increasing order is very efficient
assert_eq!(seq_reader.get(10)?, Some(10));
assert_eq!(seq_reader.get(15)?, Some(15)); // Decodes forward from index 10
assert_eq!(seq_reader.get(90)?, Some(90)); // Jumps to a new sample

Implementations§

Source§

impl<'a, T: Storable, E: Endianness, B: AsRef<[u64]>> VarVecSeqReader<'a, T, E, B>
where for<'b> BufBitReader<E, MemWordReader<u64, &'b [u64], true>, DefaultReadParams>: BitRead<E, Error = Infallible> + CodesRead<E> + BitSeek<Error = Infallible>,

Source

pub fn get(&mut self, index: usize) -> Result<Option<T>, VarVecError>

Retrieves the element at index, or None if out of bounds.

This method leverages the reader’s internal state to optimize access, especially for sequential reads.

Source

pub unsafe fn get_unchecked(&mut self, index: usize) -> T

Retrieves the element at index without bounds checking.

§Safety

Calling this method with an out-of-bounds index is undefined behavior. The caller must ensure that index < self.intvec.len().

Trait Implementations§

Source§

impl<T: Storable, E: Endianness, B: AsRef<[u64]>> Debug for VarVecSeqReader<'_, T, E, B>
where for<'b> BufBitReader<E, MemWordReader<u64, &'b [u64], true>, DefaultReadParams>: BitRead<E, Error = Infallible> + CodesRead<E> + BitSeek<Error = Infallible>,

Source§

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

§

impl<'a, T, E, B> Freeze for VarVecSeqReader<'a, T, E, B>

§

impl<'a, T, E, B> RefUnwindSafe for VarVecSeqReader<'a, T, E, B>

§

impl<'a, T, E, B> Send for VarVecSeqReader<'a, T, E, B>
where B: Sync, T: Sync,

§

impl<'a, T, E, B> Sync for VarVecSeqReader<'a, T, E, B>
where B: Sync, T: Sync,

§

impl<'a, T, E, B> Unpin for VarVecSeqReader<'a, T, E, B>
where E: Unpin,

§

impl<'a, T, E, B> UnsafeUnpin for VarVecSeqReader<'a, T, E, B>

§

impl<'a, T, E, B> UnwindSafe for VarVecSeqReader<'a, T, E, B>

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CastableFrom<T> for T

Source§

fn cast_from(value: T) -> T

Call Self as W
Source§

impl<T, U> CastableInto<U> for T
where U: CastableFrom<T>,

Source§

fn cast(self) -> U

Call W::cast_from(self)
Source§

impl<T> DowncastableFrom<T> for T

Source§

fn downcast_from(value: T) -> T

Truncate the current UnsignedInt to a possibly smaller size
Source§

impl<T, U> DowncastableInto<U> for T
where U: DowncastableFrom<T>,

Source§

fn downcast(self) -> U

Call W::downcast_from(self)
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

impl<T> Pointable for T

Source§

const ALIGN: usize

The alignment of pointer.
Source§

type Init = T

The type for initializers.
Source§

unsafe fn init(init: <T as Pointable>::Init) -> usize

Initializes a with the given initializer. Read more
Source§

unsafe fn deref<'a>(ptr: usize) -> &'a T

Dereferences the given pointer. Read more
Source§

unsafe fn deref_mut<'a>(ptr: usize) -> &'a mut T

Mutably dereferences the given pointer. Read more
Source§

unsafe fn drop(ptr: usize)

Drops the object pointed to by the given pointer. Read more
Source§

impl<T> Splat<T> for T

Source§

fn splat(value: T) -> T

Source§

impl<T> To<T> for T

Source§

fn to(self) -> T

Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.
Source§

impl<T> UpcastableFrom<T> for T

Source§

fn upcast_from(value: T) -> T

Extend the current UnsignedInt to a possibly bigger size.
Source§

impl<T, U> UpcastableInto<U> for T
where U: UpcastableFrom<T>,

Source§

fn upcast(self) -> U

Call W::upcast_from(self)