Skip to main content

SegmentReader

Struct SegmentReader 

Source
pub struct SegmentReader<'a> { /* private fields */ }
Expand description

Reads and decodes columns from a segment byte buffer.

Supports column projection (only decode requested columns) and block predicate pushdown (skip blocks whose stats prove no match).

Implementations§

Source§

impl<'a> SegmentReader<'a>

Source

pub fn open(data: &'a [u8]) -> Result<Self, ColumnarError>

Open a segment from a byte buffer. Validates header and footer CRC.

Source

pub fn footer(&self) -> &SegmentFooter

Access the footer metadata.

Source

pub fn row_count(&self) -> u64

Total row count in the segment.

Source

pub fn column_count(&self) -> usize

Number of columns in the segment.

Source

pub fn read_column( &self, col_idx: usize, ) -> Result<DecodedColumn, ColumnarError>

Read a single column, decoding all blocks.

col_idx is the column index in the footer’s column metadata.

Source

pub fn read_column_filtered( &self, col_idx: usize, predicates: &[ScanPredicate], ) -> Result<DecodedColumn, ColumnarError>

Read a single column with predicate pushdown.

Blocks whose stats satisfy the predicates are skipped. For skipped blocks, null/zero-fill rows are emitted to preserve row alignment across projected columns.

Source

pub fn read_columns( &self, col_indices: &[usize], predicates: &[ScanPredicate], ) -> Result<Vec<DecodedColumn>, ColumnarError>

Read multiple columns with shared predicate pushdown.

All columns share the same block skip decisions so row alignment is maintained across the result set.

Source

pub fn read_column_with_deletes( &self, col_idx: usize, predicates: &[ScanPredicate], deletes: &DeleteBitmap, ) -> Result<DecodedColumn, ColumnarError>

Read a column with both predicate pushdown and delete bitmap masking.

Deleted rows have their validity set to false in the output. Fully deleted blocks are skipped entirely (no decompression).

Source

pub fn read_columns_with_deletes( &self, col_indices: &[usize], predicates: &[ScanPredicate], deletes: &DeleteBitmap, ) -> Result<Vec<DecodedColumn>, ColumnarError>

Read multiple columns with predicate pushdown and delete bitmap.

Auto Trait Implementations§

§

impl<'a> Freeze for SegmentReader<'a>

§

impl<'a> RefUnwindSafe for SegmentReader<'a>

§

impl<'a> Send for SegmentReader<'a>

§

impl<'a> Sync for SegmentReader<'a>

§

impl<'a> Unpin for SegmentReader<'a>

§

impl<'a> UnsafeUnpin for SegmentReader<'a>

§

impl<'a> UnwindSafe for SegmentReader<'a>

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> ArchivePointee for T

Source§

type ArchivedMetadata = ()

The archived version of the pointer metadata for this type.
Source§

fn pointer_metadata( _: &<T as ArchivePointee>::ArchivedMetadata, ) -> <T as Pointee>::Metadata

Converts some archived metadata to the pointer metadata for itself.
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> 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> LayoutRaw for T

Source§

fn layout_raw(_: <T as Pointee>::Metadata) -> Result<Layout, LayoutError>

Returns the layout of the type.
Source§

impl<T, N1, N2> Niching<NichedOption<T, N1>> for N2
where T: SharedNiching<N1, N2>, N1: Niching<T>, N2: Niching<T>,

Source§

unsafe fn is_niched(niched: *const NichedOption<T, N1>) -> bool

Returns whether the given value has been niched. Read more
Source§

fn resolve_niched(out: Place<NichedOption<T, N1>>)

Writes data to out indicating that a T is niched.
Source§

impl<T> Pointee for T

Source§

type Metadata = ()

The metadata type for pointers and references to this type.
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<V, T> VZip<V> for T
where V: MultiLane<T>,

Source§

fn vzip(self) -> V